C++在多线程中使用condition_variable实现wait

更新时间：2022年09月20日 09:12:32 作者：君子以阅川

这篇文章主要介绍了C++中的condition_variable中在多线程中的使用，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习吧

前言

有这样的需求

一个线程需要等待另一个线程执行完毕之后它才会继续向下执行，这该如何实现？ condition_variable类中实现了wait方法

wait()

可以接受两个参数，其中第一个参数是锁对象，第二个参数是lambda表达式，其中的lambda表达式的返回值要是bool类型
也可接受一个参数，仅仅接受锁对象

#include<iostream>
#include<mutex>
#include<list>
#include<thread>
using namespace std;
class Obj
{
private:
	list<int> myList;
	condition_variable var;
	mutex tex;
public:
	bool popFromList(int & comb)
	{
		if (!myList.empty()) {
			unique_lock<mutex> cur(tex);
			if (!myList.empty())
			{
				comb = myList.front();
				myList.pop_front();
				return true;
			}
		}
		return false;
	}
	void inToList()
	{
		for (int i = 0; i < 100; i++)
		{
			unique_lock<mutex> cur(tex);
			myList.push_back(i);
			cout << this_thread::get_id() << "正在向list中添加数据>; " << i << endl;
			var.notify_one();
		}
	}
	void outFromList()
	{
		while(true)
		{
			unique_lock<mutex> cur(tex);
			var.wait(cur, [this] {
				if (!myList.empty())
					return true;
				return false;
				});
			int comb = myList.front();
			myList.pop_front();
			cout << this_thread::get_id() << "正在取出数据>: " << comb << endl;
		}
	}
};
int main()
{
	Obj obj;
	thread thread1(&Obj::outFromList, &obj);
	thread thread2(&Obj::inToList, &obj);
	thread1.join();
	thread2.join();
	cout << "这里是主线程" << endl;
}

线程1执行到wait函数时，会执行lambda表达式

返回值为false时，这个线程就会将锁打开，将该线程压入到栈中，执行下一个线程下一个线程执行完毕之后执行notify_one后就会返回到该线程，继续执行lambda表达式

返回值为true时就尝试获得锁

获得锁后继续执行下面的语句

没有获得锁就继续卡在wait等待获取到锁

返回值为false时，继续将锁打开，线程压入栈，执行下一个线程

返回值为true时，线程继续执行

运行结果可能是一个线程执行完毕另一个线程再执行

这不就是顺序执行吗？

其实并不是这样的

notify_one()

唤醒wait()函数，当前所再的线程尝试获得锁

某个线程执行完notify_one函数后，会返回到另一个线程中的wait函数处，并将其"唤醒"，让其继续执行，自己的线程和wait线程都尝试获得锁来进行下一步执行

不是顺序执行的解释

当wait函数后面有很多语句要执行，但是再此之前wait所在的线程函数中就已经将锁进行释放了，那么notify_one的“唤醒”就不在生效，两个线程都尝试获得锁，但是wait所在的线程有很多语句要执行，耗时高，那么很有可能notify_one所在的线程就再次获得了锁，进行下一步操作。
这样就不一定是顺序执行的宏观表现了

#include<iostream>
#include<mutex>
#include<list>
#include<thread>
using namespace std;
class Obj
{
private:
	list<int> myList;
	condition_variable var;
	mutex tex;
public:
	bool popFromList(int & comb)
	{
		if (!myList.empty()) {
			unique_lock<mutex> cur(tex);
			if (!myList.empty())
			{
				comb = myList.front();
				myList.pop_front();
				return true;
			}
		}
		return false;
	}
	void inToList()
	{
		for (int i = 0; i < 1000; i++)
		{
			cout << this_thread::get_id() << "正在向list中添加数据>; " << i << endl;
			unique_lock<mutex> cur(tex);
			myList.push_back(i);
			var.notify_one();
		}
	}
	void outFromList()
	{
		while(true)
		{
			unique_lock<mutex> cur(tex);
			var.wait(cur, [this] {
				if (!myList.empty())
					return true;
				return false;
				});
			int comb = myList.front();
			myList.pop_front();
			cur.unlock();
			cout << this_thread::get_id() << "正在取出数据>: " << comb << endl;
			chrono::seconds tim(2);
			this_thread::sleep_for(tim);
			cout <<this_thread::get_id() <<  "睡眠两秒后执行" << endl;
		}
	}
};
int main()
{
	Obj obj;
	thread thread1(&Obj::outFromList, &obj);
	thread thread2(&Obj::inToList, &obj);
	thread1.join();
	thread2.join();
	cout << "这里是主线程" << endl;
}

如图所示，在notify_one线程执行835次循环后，wait所在的线程才获得了锁，继续执行

在此之前的所有notify_one的唤醒操作都是无效的。

然后在notify_one线程执行完毕之后，wait再次获得了锁，继续向下执行

notify_all()

顾名思义，是“唤醒”所有的wait函数线程，但是并不是都一起运行，因为他们要进行锁的请求，仅仅只能由一把锁存在，只有获得锁并且lambda表达式返回结果为true的线程才能继续执行

到此这篇关于C++在多线程中使用condition_variable实现wait的文章就介绍到这了,更多相关C++ condition_variable内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

C语言实现求解素数的N种方法总结
哈喽各位友友们，今天又学到了很多有趣的知识，现在迫不及待的想和大家分享一下！本文将手把手带领大家探讨利用试除法、筛选法求解素数的n层境界！都是精华内容，可不要错过哟
2023-01-01
C++11生成随机数(random库)的使用
随机数在很多地方都可以用到，本文主要介绍了C++11生成随机数(random库)的使用，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2022-01-01
浅析C语言中printf(),sprintf(),scanf(),sscanf()的用法和区别
以下是对C语言中printf(),sprintf(),scanf(),sscanf()的用法以及区别进行了详细的分析介绍，需要的朋友可以参考下
2013-07-07
C++通过共享内存ShellCode实现跨进程传输
在计算机安全领域,ShellCode是一段用于利用系统漏洞或执行特定任务的机器码,本文主要为大家介绍了C++如何通过共享内存ShellCode实现跨进程传输,需要的可以参考下
2023-12-12
快速学习六大排序算法
这篇文章主要介绍了六大排序算法-插入排序、希尔排序、选择排序、冒泡排序、堆排序、快速排序，需要学习的小伙伴可以参考这篇文章
2021-08-08
C语言命令行参数的使用详解
本文主要介绍了C语言命令行参数的使用详解，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2021-07-07
C++任意线程通过hwnd实现将操作发送到UI线程执行
做Windows界面开发时,经常需要在多线程环境中将操作抛到主线程执行,下面我们就来学习一下如何在不需要重新定义消息以及接收消息的情况下实现这一要求,感兴趣的可以了解下
2024-03-03
C语言实现飞机大战
这篇文章主要为大家详细介绍了C语言实现飞机大战，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2022-06-06
深入分析C++中两个大数相乘结果不正确的问题
本篇文章是对C++中两个大数相乘结果不正确的问题进行了详细的分析介绍，需要的朋友参考下
2013-05-05
Qt5.9实现简单复合图形
这篇文章主要为大家详细介绍了Qt5.9实现简单复合图形，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2020-07-07