C++ std::wait与std::condition_variable,notify_one()的使用
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即可。
如有错误还请指正
上一篇:
通过多线程提高代码的执行效率例子
下一篇:
java学习4---枚举类型与泛型