admin管理员组

文章数量:1599537

wait()用来等一个东西
如果第二个参数,lambda返回值是true,那wait()直接返回;
如果第二个参数lambda表达式返回值是false,那么wait()将解锁互斥量,并堵塞到本行
那么堵塞到什么时候呢?堵塞到其他线程调用notify_one()成员函数为止
如果wait()没有第二个参数:那么跟第二个参数lambda表达式返回值为false效果一样
wait()将解锁互斥量,并堵塞到本行,堵塞到其他某个线程调用notify_one()成员函数为止

#include <iostream>                
#include <thread>                
#include <mutex>                
#include <condition_variable>    // std::condition_variable
std::condition_variable av;
class Test {
private:
	std::mutex ab;
	int i = 0;
public:
	void test()
	{
		std::unique_lock<std::mutex>A(ab);
		std::cout << i++ << std::endl;
		av.wait(A);//默认false
		std::cout << i++ + 100 << std::endl;
	}
};
void go() {
	av.notify_all();
	std::cout << "结束" << std::endl;
}
int main() {
	Test a;
	std::jthread T[20];
	for (auto& i : T)
		i = std::jthread(&Test::test, &a);
	std::this_thread::sleep_for(std::chrono::milliseconds(10));
	go();
	return 0;
}

我们都采用不写第二个参数,即默认false,lambda表达式即可调用对象都可以作为wait的第二个参数。上面这串代码已经描述的很清楚了,调试理解即可。std::condition_variable是一个类,它创建的对象的成员函数wait用来阻塞。所有线程都会阻塞到拿回那行,直到有一个线程调用了notify_one()成员函数,我们这里采用的是主线程调用。

没sleep的话可能会出现你有的线程还没跑到wait你就notify_all了,一定要注意
先要让所有线程都堵塞到那里才行
如果不延时,那么只有一部分线程运行到那里,问题就很大了

那么它有什么用呢?举一个最简单的例子,我们想要先创建完所有的线程然后再让它们启动

代码如下

#include <iostream>                
#include <thread>                
#include <mutex>                
#include <condition_variable>    // std::condition_variable
std::condition_variable av;
class Test {
private:
	std::mutex ab;
	int i = 0;
public:
	void test()
	{
		std::unique_lock<std::mutex>A(ab);
		std::cout << i++ << std::endl;
		av.wait(A);//默认false
		std::cout << i++ + 100 << std::endl;
	}
};
void go() {
	av.notify_all();
	std::cout << "结束" << std::endl;
}
int main() {
	Test a;
	std::jthread T[20];
	for (auto& i : T)
		i = std::jthread(&Test::test, &a);
	std::this_thread::sleep_for(std::chrono::milliseconds(10));
	go();
	return 0;
}

一定要注意,开头的几句话深入理解即可。

我们采用MSVC,C++20,std::jthread,如果你的编译器不支持,换成thread,然后调用join即可。

如有错误还请指正

本文标签: waitstdnotifyoneconditionvariable