admin管理员组文章数量:1599541
目录
一.std::condition_variable
二.std::condition_variable::wait()
三.notify_one
四.notify_all
一.std::condition_variable
std::condition-variable实际上是一个类,是一个和条件相关的一个类,说白了就是等待一个条件达成。这个类是需要和互斥量来配合工作,用的时候我们要生成这个类的对象。
二.std::condition_variable::wait()
wait()用来等一个东西
如果第二个参数lambda表达式返回值是true,那wait()直接返回;
如果第二个参数lambda表达式返回值是false,那么wait()将解锁互斥量,并堵塞到本行,
那堵塞到什么时候为止呢?堵塞到其他某个线程调用notify_one()成员函数为止;
如果wait()没有第二个参数:data_cond.wait(lk):那么就跟第二个参数lambda表达式返回false效果一样
wait()将解锁互斥量,并堵塞到本行,堵塞到其他某个线程调用notify_one()成员函数为止;
当其他线程用notify_one()将本wait(原来睡着/堵塞)的状态唤醒后,wait就开始恢复干活了,恢复后wait干什么活?
1.wait()不断的尝试重新获取互斥量锁,如果还获取不到,那么流程就卡在wait这里等着获取,如果获取到了锁,那么wait就继续执行
2.如果wait有第二个参数(lambda),就判断这个lambda表达式,如果lambda表达式为false,那wait又对互斥量解锁,然后又休眠这里等待下次被notify_one唤醒
3.如果lambda表达式为true,则wait返回,流程走下来(此时互斥锁被锁着)。
4.如果wait没有第二个参数,则wait返回,流程走下来。
三.notify_one
唤醒一个线程的wait()
四.notify_all
唤醒所有线程的wait()
#include <list>
#include <mutex>
#include <condition_variable>
std::mutex mut;
std::list<data_chunk> data_list; // 1
std::condition_variable data_cond;
void data_preparation_thread()
{
while(more_data_to_prepare())
{
data_chunk const data=prepare_data();
std::lock_guard<std::mutex> lk(mut);
data_list.push_back(data); //插入数据
data_cond.notify_one(); //把wait()的线程唤醒
}
}
void data_processing_thread()
{
while(true)
{
std::unique_lock<std::mutex> lk(mut); //这里无第二个参书unique_lock
data_cond.wait(lk,[]{return !data_queue.empty();}); //lambda表达式作为第二个参数
data_chunk data=data_lsit.front();
data_list.pop();//移除第一个元素
lk.unlock();
process(data);
if(is_last_chunk(data))
break;
}
}
本文标签: 多线程conditionvariablenotifyonewait
版权声明:本文标题:【C++】C++并发与多线程condition_variable、wait、notify_one 内容由热心网友自发贡献,该文观点仅代表作者本人, 转载请联系作者并注明出处:https://m.elefans.com/dianzi/1728322545a1154014.html, 本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容,一经查实,本站将立刻删除。
发表评论