标签：msgRecvQueue wait 互斥 notify variable include condition lambda

1）condition_variable、wait()、notify_one()

// test.cpp : 此文件包含 "main" 函数。程序执行将在此处开始并结束。
#include <iostream>
#include <string>
#include <vector>
#include <stack>
#include <queue>
#include <map>
#include <set>
#include <list>
#include <thread>
#include <chrono>
#include <mutex>
#include <string>
 
using namespace std;
 
class A
{
private:
	list<int> msgRecvQueue;
	mutex m_mutex;
	condition_variable m_cond;
public:
	void inMsgQueue()
	{
		for (int i = 0; i < 100000; i++)
		{
			cout << "inMsgQueue() 执行了，插入了一个元素：" << i << endl;
			unique_lock<mutex> mymutex(m_mutex);
			msgRecvQueue.push_back(i);
			m_cond.notify_one();//我们尝试把wait()线程唤醒，那么outMsgQueue()中的wait()就被唤醒了。notify_one() 不能百分之百保证能够把线程唤醒
		}
	}
 
	void outMsgQueue()
	{
		int command = 0;
		while (true)
		{
			//1.wait()用来等一个东西。
			//2.如果第二个参数lambda表达式为false，那么wait()将解锁互斥量，并堵塞到本行，那么堵塞到什么时候为止呢？
			//堵塞到其他线程调用notify_one()成员函数为止；
			//3.如果wait()没有第二个参数：m_cond.wait(mymutex);那么就跟第二个参数lambda表达式返回false效果一样，也就是
			//那么wait()将解锁互斥量，并堵塞到本行，堵塞到其他线程调用notify_one()成员函数为止；
			//4.如果第二个参数lambda表达式为true，那么wait()直接返回。
 
			//当其他线程调用notify_one()将本wait(原来是睡着/堵塞)的状态唤醒后，wait()就开始恢复干活了，恢复后wait()干什么呢？
			//a.wait()不断的尝试重新获取互斥量，如果获取不到，那么流程就卡在wait()这里等着获取，如果获取到了锁(等于加了锁)。
 
			//b.
			//b.1 如果wait()有第二个参数(lambda)，就判断这个lambda表达式，如果lambda表达式为false,那么wait又对这个互斥量解锁,并堵塞到本行,
			// 然后又在这里休眠，等待再次被notify_one()唤醒。
			//b.2 如果lambda 表达式为true,则wait()返回，流程走下来(此时互斥量被锁住)。
			//b.3 wait没有第二个参数，则wait返回，流程走下来
			unique_lock<mutex> mymutex(m_mutex);
			m_cond.wait(mymutex, [this] {
				if (!msgRecvQueue.empty())
					return true;
				return false;
				});
 
			//流程只要能够走到这里来，这个互斥锁一定是锁住的，同时msgRecvQueue至少是有一条数据的。
			command = msgRecvQueue.front();
			msgRecvQueue.pop_front();
			mymutex.unlock(); // 提前解锁，以便影响其他线程得到锁，以免锁住太长时间，体现了unique_lock 的方便性。
			cout << "outMsgQueue()执行，取出一个元素：" << command << endl;
		}
	}
};
 
int main()
{
	A obj;
 
	thread outThread(&A::outMsgQueue, &obj);
	thread inThread(&A::inMsgQueue,&obj);
	
 
	outThread.join();
	inThread.join();
	
 
	return 0;
}

标签：msgRecvQueue,wait,互斥,notify,variable,include,condition,lambda
来源： https://www.cnblogs.com/xiaochouk/p/16407179.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。