c++多线程为何要使用条件变量详解
先看示例1:
#include <iostream> #include <windows.h> #include <mutex> #include<deque> #include <thread> using namespace std; int nmax = 20; std::deque<int> m_que; std::mutex mymutex; //生产者 void producterex() { int i = 1; while (i<nmax) { //休眠一秒钟 std::this_thread::sleep_for(std::chrono::seconds(1)); std::unique_lock<mutex> lcx(mymutex); m_que.push_back(i); cout << "producted:" << i << endl; lcx.unlock(); i++; } cout << "product thread exit\n"; } //消费者 void consumerex() { int i = 0; while (1) { std::unique_lock<mutex> lcx(mymutex); if (!m_que.empty()) { int i = m_que.back(); m_que.pop_back(); cout << "consumed:" << i << endl; lcx.unlock(); i++; if (i == nmax) { break; } } else { lcx.unlock(); } } cout << "consumerex thread exit\n"; } void main() { std::thread t1(producterex); std::thread t2(consumerex); t1.detach(); cout << "hello"; t2.detach(); cout << " world!\n"; getchar(); system("pause"); }
结果:
可见cpu使用率非常高。高的原因主要在消费者线程中,因为当队列为空的时候它也要执行,做了过多的无用功导致CPU占有率过高,所以下面对进行一个改造让其在空的时候等待200毫秒,相当于增大了轮询间隔周期,应该能降低CPU的占用率。
在这里就贴上消费者的线程,因为其它的都一样。
//消费者 void consumerex() { int i = 0; while (1) { std::unique_lock<mutex> lcx(mymutex); if (!m_que.empty()) { int i = m_que.back(); m_que.pop_back(); cout << "consumed:" << i << endl; lcx.unlock(); i++; if (i == nmax) { break; } } else { lcx.unlock(); std::this_thread::sleep_for(std::chrono::milliseconds(200)); } } cout << "consumerex thread exit\n"; }
结果:
可见CPU占用率一下子下降了。
这里就有一个困难了,那就是如何确定休眠的时间间隔(即轮询间隔周期),如果间隔太短会过多占用CPU资源,如果间隔太长会因无法及时响应造成延误。
这就引入了条件变量来解决该问题:条件变量使用“通知—唤醒”模型,生产者生产出一个数据后通知消费者使用,消费者在未接到通知前处于休眠状态节约CPU资源;当消费者收到通知后,赶紧从休眠状态被唤醒来处理数据,使用了事件驱动模型,在保证不误事儿的情况下尽可能减少无用功降低对资源的消耗。
condition_variable介绍
在C++11中,我们可以使用条件变量(condition_variable)实现多个线程间的同步操作;当条件不满足时,相关线程被一直阻塞,直到某种条件出现,这些线程才会被唤醒。
成员函数如下:
条件变量是利用线程间共享的全局变量进行同步的一种机制,主要包括两个动作:
a.一个线程因等待"条件变量的条件成立"而挂起;
b.另外一个线程使"条件成立",给出信号,从而唤醒被等待的线程。
为了防止竞争,条件变量的使用总是和一个互斥锁结合在一起;通常情况下这个锁是std::mutex,并且管理这个锁 只能是 std::unique_lockstd::mutex RAII模板类。
上面提到的两个步骤,分别是使用以下两个方法实现:
1.等待条件成立使用的是condition_variable类成员wait 、wait_for 或 wait_until。
2.给出信号使用的是condition_variable类成员notify_one或者notify_all函数。
以上两个类型的wait函数都在会阻塞时,自动释放锁权限,即调用unique_lock的成员函数unlock(),以便其他线程能有机会获得锁。这就是条件变量只能和unique_lock一起使用的原因,否则当前线程一直占有锁,线程被阻塞。
虚假唤醒
在正常情况下,wait类型函数返回时要不是因为被唤醒,要不是因为超时才返回,但是在==实际中发现,因此操作系统的原因,wait类型在不满足条件时,它也会返回,这就导致了虚假唤醒。==因此,我们一般都是使用带有谓词参数的wait函数,因为这种(xxx, Predicate pred )类型的函数等价于:
while (!pred()) //while循环,解决了虚假唤醒的问题 { wait(lock); }
原因说明如下:
假设系统不存在虚假唤醒的时,代码形式如下:
if (不满足xxx条件) { //没有虚假唤醒,wait函数可以一直等待,直到被唤醒或者超时,没有问题。 //但实际中却存在虚假唤醒,导致假设不成立,wait不会继续等待,跳出if语句, //提前执行其他代码,流程异常 wait(); } //其他代码 ...
正确的使用方式,使用while语句解决:
while (!(xxx条件) ) { //虚假唤醒发生,由于while循环,再次检查条件是否满足, //否则继续等待,解决虚假唤醒 wait(); } //其他代码 ....
下面看一个使用条件变量的情况:
#include <iostream> #include <windows.h> #include <mutex> #include<deque> #include <thread> #include<condition_variable> using namespace std; int nmax = 10; std::deque<int> m_que; std::mutex mymutex; condition_variable mycv; //生产者 void producterex() { int i = 1; while (i<nmax) { //休眠一秒钟 std::this_thread::sleep_for(std::chrono::seconds(1)); std::unique_lock<mutex> lcx(mymutex); m_que.push_back(i); cout << "producted:" << i << endl; lcx.unlock(); mycv.notify_one(); i++; } cout << "product thread exit\n"; } //消费者 bool m_bflag = false; void consumerex() { int i = 0; bool m_bexit = false; while (!m_bexit) { std::unique_lock<mutex> lcx(mymutex); while (m_que.empty()) { //避免虚假唤醒 mycv.wait(lcx); if (m_bflag) { cout << "consumerex thread exit\n"; m_bexit = true; break; } } if (m_bexit) { break; } int i = m_que.back(); m_que.pop_back(); lcx.unlock(); cout << "consumed:" << i << endl; } cout << "consumerex thread exit\n"; } void main() { std::thread t1(producterex); std::thread t2(consumerex); t1.detach(); cout << "hello"; t2.detach(); cout << " world!\n"; mycv.notify_one(); Sleep(15000); m_que.push_back(100); mycv.notify_one(); Sleep(3000); m_bflag = true; mycv.notify_one();//通知线程退出 getchar(); system("pause"); }
结果:
还可以将mycv.wait(lcx);换一种写法,wait()的第二个参数可以传入一个函数表示检查条件,这里使用lambda函数最为简单,如果这个函数返回的是true,wait()函数不会阻塞会直接返回,如果这个函数返回的是false,wait()函数就会阻塞着等待唤醒,如果被伪唤醒,会继续判断函数返回值。代码示例如下:
#include <iostream> #include <windows.h> #include <mutex> #include<deque> #include <thread> #include<condition_variable> using namespace std; int nmax = 10; std::deque<int> m_que; std::mutex mymutex; condition_variable mycv; //生产者 void producterex() { int i = 1; while (i<nmax) { //休眠一秒钟 std::this_thread::sleep_for(std::chrono::seconds(1)); std::unique_lock<mutex> lcx(mymutex); m_que.push_back(i); cout << "producted:" << i << endl; lcx.unlock(); mycv.notify_one(); i++; } cout << "product thread exit\n"; } //消费者 bool m_bflag = false; void consumerex() { int i = 0; while (1) { std::unique_lock<mutex> lcx(mymutex); mycv.wait(lcx, [](){ //返回false就继续等待 return !m_que.empty(); }); if (m_bflag) { break; } int i = m_que.back(); m_que.pop_back(); lcx.unlock(); cout << "consumed:" << i << endl; } cout << "consumerex thread exit\n"; } void main() { std::thread t1(producterex); std::thread t2(consumerex); t1.detach(); cout << "hello"; t2.detach(); cout << " world!\n"; mycv.notify_one(); Sleep(15000); m_que.push_back(100); mycv.notify_one(); Sleep(3000); m_bflag = true; m_que.push_back(-1); mycv.notify_one();//通知线程退出 getchar(); system("pause"); }
总结
到此这篇关于c++多线程为何要使用条件变量的文章就介绍到这了,更多相关c++多线程条件变量内容请搜索猪先飞以前的文章或继续浏览下面的相关文章希望大家以后多多支持猪先飞!
相关文章
C# WinForm多线程解决界面卡死问题的完美解决方案,使用BeginInvoke
问题描述:当我们的界面需要在程序运行中不断更新数据时,当一个textbox的数据需要变化时,为了让程序执行中不出现界面卡死的现像,最好的方法就是多线程来解决一个主线程来创建界...2020-06-24- vector是表示可以改变大小的数组的序列容器,本文主要介绍了C++STL标准库std::vector的使用详解,文中通过示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...2022-03-06
- 下面本文章来给大家介绍在php中成员变量的一些对比了,文章举了四个例子在这例子中分别对不同成员变量进行测试与获取操作,下面一起来看看。 有如下4个代码示例,你认...2016-11-25
- 这篇文章主要介绍了C++中取余运算的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-02-23
- 这篇文章主要介绍了C++ string常用截取字符串方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2020-04-25
- 本文通过例子,讲述了C++调用C#的DLL程序的方法,作出了以下总结,下面就让我们一起来学习吧。...2020-06-25
- 本文主要介绍了C#变量命名规则小结,文中介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...2021-09-09
- 这篇文章主要介绍了R语言删除指定变量或对象的操作方法,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-05-06
- 本篇文章主要介绍了C++中四种加密算法之AES源代码,小编觉得挺不错的,现在分享给大家,也给大家做个参考。...2020-04-25
- 整数拆分,指把一个整数分解成若干个整数的和。本文重点给大家介绍C++ 整数拆分方法详解,非常不错,感兴趣的朋友一起学习吧...2020-04-25
解决vue的router组件component在import时不能使用变量问题
这篇文章主要介绍了解决vue的router组件component在import时不能使用变量问题,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2020-07-27- 这篇文章主要介绍了C++中Sort函数详细解析,sort函数是algorithm库下的一个函数,sort函数是不稳定的,即大小相同的元素在排序后相对顺序可能发生改变...2022-08-18
- 这篇文章主要介绍了c# 多线程处理多个数据的方法,帮助大家更好的理解和学习使用c#,感兴趣的朋友可以了解下...2021-03-31
- 这篇文章主要介绍了C++万能库头文件在vs中的安装步骤(图文),文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-02-23
- 这篇文章主要介绍了Vue select 绑定动态变量的实例讲解,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2020-10-23
- 在PHP中,大部分变量类型,如字符串,整型,浮点,数组等都是值类型的,而类和对象是引用类型,在使用的时候,需要注意这一点。看到网友在讨论PHP的&符号,要彻底理解它的用法,就有必要讨论一下变量的两种形式。PHP的变量在内存中是这样...2015-10-23
- 这篇文章主要介绍了C#基于委托实现多线程之间操作的方法,实例分析了C#的委托机制与多线程交互操作的相关技巧,具有一定参考借鉴价值,需要的朋友可以参考下...2020-06-25
- 这篇文章主要介绍了C++ bitset用法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2020-04-25
- 本篇文章小编并不是为大家讲解string类型的用法,而是讲解我个人比较好奇的问题,就是string 类型占几个字节...2020-04-25
- 这篇文章主要介绍了C#多线程中的异常处理操作,涉及C#多线程及异常的捕获、处理等相关操作技巧,需要的朋友可以参考下...2020-06-25