当前位置: 首页 > news >正文

私人定制平台网站厦门seo关键词优化培训

私人定制平台网站,厦门seo关键词优化培训,徐州泉山建设局网站,威县企业做网站C11并发与多线程笔记(12) windows临界区、其他各种mutex互斥量 1、windows临界区2、自动析构技术3、递归独占互斥量 std::recursive_mutex4、带超时的互斥量 std::timed_mutex 和 std::recursive_timed_mutex4.1 std::timed_mutex:是带超时的…

C++11并发与多线程笔记(12) windows临界区、其他各种mutex互斥量

  • 1、windows临界区
  • 2、自动析构技术
  • 3、递归独占互斥量 std::recursive_mutex
  • 4、带超时的互斥量 std::timed_mutex 和 std::recursive_timed_mutex
    • 4.1 std::timed_mutex:是带超时的独占互斥量
    • 4.2 std::recursive_timed_mutex:是带超时的递归独占互斥量

1、windows临界区

Windows临界区,同一个线程是可以重复进入的,但是进入的次数与离开的次数必须相等。
C++互斥量则不允许同一个线程重复加锁 (相同的mutex变量不容许连续调用)。

windows临界区是在windows编程中的内容,了解一下即可,效果几乎可以等同于c++11的mutex
包含**#include <windows.h>**
windows中的临界区同mutex一样,可以保护一个代码段。但windows的临界区可以进入多次,离开多次,但是进入的次数与离开的次数必须相等,不会引起程序报异常出错。

#include <iostream>
#include <thread>
#include <list>
#include <mutex>
#include <Windows.h>#define __WINDOWSJQ_using namespace std;class A
{
public:// 把收到的消息传入队列void inMsgRecvQueue(){for (size_t i = 0; i < 10000; ++i){cout << "收到消息,并放入队列 " << i << endl;
//windows开关
#ifdef  __WINDOWSJQ_ EnterCriticalSection(&my_winsec);	//	进入临界区//EnterCriticalSection(&my_winsec);	//	可以再次进入临界区,程序不会出错msgRecvQueue.push_back(i);LeaveCriticalSection(&my_winsec);	//	离开临界区//LeaveCriticalSection(&my_winsec);	//	如果进入两次,必须离开两次不会报错
#elsemy_mutex.lock();msgRecvQueue.push_back(i);my_mutex.unlock();
#endif //  __WINDOWSJQ_}cout << "消息入队结束" << endl;}// 从队列中取出消息void outMsgRecvQueue(){for (size_t i = 0; i < 10000; ++i){
#ifdef  __WINDOWSJQ_EnterCriticalSection(&my_winsec);	//	进入临界区if (!msgRecvQueue.empty()){// 队列不为空int num = msgRecvQueue.front();cout << "从消息队列中取出 " << num << endl;msgRecvQueue.pop_front();}else{// 消息队列为空cout << "消息队列为空 " << endl;}LeaveCriticalSection(&my_winsec);	//	离开临界区
#elsemy_mutex.lock();if (!msgRecvQueue.empty()){// 队列不为空int num = msgRecvQueue.front();cout << "从消息队列中取出 " << num << endl;msgRecvQueue.pop_front();my_mutex.unlock();}else{// 消息队列为空cout << "消息队列为空 " << endl;my_mutex.unlock();}
#endif //  __WINDOWSJQ_}cout << "消息出队结束" << endl;}A(){
#ifdef __WINDOWSJQ_InitializeCriticalSection(&my_winsec);	//	用临界区之前要初始化
#endif // __WINDOWSJQ_}private:list<int> msgRecvQueue;mutex my_mutex;#ifdef __WINDOWSJQ_CRITICAL_SECTION my_winsec;	//	windows中的临界区,非常类似C++11中的mutex,使用之前必须初始化
#endif // __WINDOWSJQ_};int main()
{A myobj;thread	myInMsgObj(&A::inMsgRecvQueue, &myobj);thread	myOutMsgObj(&A::outMsgRecvQueue, &myobj);myInMsgObj.join();myOutMsgObj.join();getchar();return 0;
}

2、自动析构技术

C++:lock_guard防止忘了释放信号量,自动释放
windows:可以写个类自动释放临界区

//本类用于自动释放windows下的临界区,防止忘记LeaveCriticalSection导致死锁情况的发生
class CWinLock {//RALL类
public:CWinLock(CRITICAL_SECTION *pCritmp)//构造函数{my_winsec =pCritmp;EnterCriticalSection(my_winsec);//进入}~CWinLock()//析构函数{LeaveCriticalSection(my_winsec);//离开}
private:CRITICAL_SECTION *my_winsec;
};class A
{
public:// 把收到的消息传入队列void inMsgRecvQueue(){for (size_t i = 0; i < 10000; ++i){cout << "收到消息,并放入队列 " << i << endl;
//windows开关
#ifdef  __WINDOWSJQ_ CWinLock wlock(&my_winsec);//调用msgRecvQueue.push_back(i);
#elsemy_mutex.lock();msgRecvQueue.push_back(i);my_mutex.unlock();
#endif //  __WINDOWSJQ_}cout << "消息入队结束" << endl;}
};

上述这种类RAII类(Resource Acquisition is initialization),即资源获取及初始化。容器,智能指针属于这种类。

3、递归独占互斥量 std::recursive_mutex

  • std::mutex: 独占式互斥量,自己lock时别人lock不了
  • std::recursive_mutex允许在同一个线程中同一个互斥量多次被 lock(),(但是递归加锁的次数是有限制的,太多可能会报异常),效率要比mutex低
void testfunc1(){std::lock_guard<std::mutex> sbguard(my_mutex);//...干各种事情testfunc2();//多次加锁,异常
}
void testfunc2(){std::lock_guard<std::mutex> sbguard(my_mutex);//...干各种另外一些事情
}

如果你真的用了 recursive_mutex 要考虑代码是否有优化空间,如果能调用一次 lock()就不要调用多次。

4、带超时的互斥量 std::timed_mutex 和 std::recursive_timed_mutex

4.1 std::timed_mutex:是带超时的独占互斥量

1. try_lock_for():等待一段时间
如果拿到了锁,或者超时了未拿到锁,就继续执行(有选择执行)如下:

std::chrono::milliseconds timeout(100);
if (my_mymutex.try_lock_for(timeout)){//......拿到锁返回turemy_mymutex.unlock();//用完了要解锁
}else{//没拿到锁,不会卡着,流程继续往下走
}

2. try_lock_until():参数是一个未来的时间点
在这个未来的时间没到的时间内,如果拿到了锁头,流程就走下来,如果时间到了没拿到锁,流程也可以走下来。

std::chrono::milliseconds timeout(100);
if (my_mymutex.try_lock_until(chrono::steady_clock::now() + timeout)){//......拿到锁返回turemy_mymutex.unlock();//用完了要解锁
}
else{//没拿到锁,不会卡着,流程继续往下走
}

两者的区别就是一个参数是时间段,一个参数是时间点

4.2 std::recursive_timed_mutex:是带超时的递归独占互斥量

允许同一个线程多次获取这个互斥量

http://www.ds6.com.cn/news/100986.html

相关文章:

  • 贷款类网站怎样做国内新闻最新消息今天
  • 个人网站做百度云电影链接犯法吗找seo外包公司需要注意什么
  • 平凉网站开发营销型网站名词解释
  • 浙江省建设信息网官网广东优化疫情防控措施
  • 济南做设计公司网站做网站建设公司
  • 深圳市盐田区建设局网站网页制作软件dreamweaver
  • 招商网站建设关键词排名seo优化
  • 做网站不给源代码谷歌浏览器官网下载安装
  • 郑州做网站的联系方式百度网盘下载安装
  • 网站开发工程师基础公司页面设计
  • 专业商业空间设计公司南昌seo排名扣费
  • 网站项目书范文网站模板平台资源
  • 建个淘宝那样的网站需要多少钱友情链接怎么互换
  • 广西汽车网网站建设谷歌官方网站首页
  • 做移动网站优化海外网站
  • 网站做哪些主题比较容易做网址收录查询
  • 对于诈骗网站怎么做营销推广的公司
  • 长春哪里有做网站的如何被百度收录
  • 怎样建立自己购物网站百度网址大全官网
  • 网站开发环境有什么关键字
  • 颍上网站建设网店运营怎么学
  • 做网站或者app百度搜索排行seo
  • 做网站1万多杭州优化建筑设计
  • 长沙制作网站软件安卓在线视频嗅探app
  • net网站开发实例爱站网
  • 外贸需要网站做生产车间展示搜索引擎seo如何赚钱
  • 专门做澳大利亚项目的网站百度指数有三个功能模块
  • 国内最好的旅游网站seo赚钱培训
  • 潍坊做电商的网站淄博搜索引擎优化
  • 没有收款接口网站怎么做收款全网seo