c++ linux 线程等待与唤醒_C++并发编程 等待与唤醒

C++并发编程 等待与唤醒

条件变量

条件变量, 包括(std::condition_variable 和 std::condition_variable_any)

定义在 condition_variable 头文件中, 它们都需要与互斥量(作为同步工具)一起才能工作.

std::condition_variable 允许阻塞一个线程, 直到条件达成.

成员函数

void wait(std::unique_lock<:mutex>& lock);

等待, 通过 notify_one(), notify_all()或伪唤醒结束等待

void wait(std::unique_lock<:mutex>& lock, Predicate pred);

等待, 通过 notify_one(), notify_all()被调用, 并且谓词为 true 时结束等待.

pred 谓词必须是合法的, 并且需要返回一个值, 这个值可以和bool互相转化

cv_status wait_until(std::unique_lock<:mutex>& lock, const std::chrono::time_point& absolute_time);

调用 notify_one(), notify_all(), 超时或线程伪唤醒时, 结束等待.

返回值标识了是否超时.

bool wait_until(std::unique_lock<:mutex>& lock, const std::chrono::time_point& absolute_time, Predicate pred);

等待, 通过 notify_one(), notify_all(), 超时, 线程伪唤醒, 并且谓词为 true 时结束等待.

cv_status wait_for(std::unique_lock<:mutex>& lock, const std::chrono::duration& relative_time);

调用 notify_one(), notify_all(), 指定时间内达成条件或线程伪唤醒时，结束等待

bool wait_for(std::unique_lock<:mutex>& lock, const std::chrono::duration& relative_time, Predicate pred);

调用 notify_one(), notify_all(), 指定时间内达成条件或线程伪唤醒时，并且谓词为 true 时结束等待.

void notify_one() noexcept; 唤醒一个等待当前 std::condition_variable 实例的线程

void notify_all() noexcept; 唤醒所有等待当前 std::condition_variable 实例的线程

一个线程安全的队列设计:

#ifndef _THREAD_SAFE_QUEUE_#define _THREAD_SAFE_QUEUE_#include#include#include#includetemplate

classThreadSafeQueue

{

typedef std::queueQueue;

typedef std::shared_ptrSharedPtr;

typedef std::lock_guardMutexLockGuard;

typedef std::unique_lockMutexUniqueLock;public:explicitThreadSafeQueue() {}~ThreadSafeQueue() {}

ThreadSafeQueue(const ThreadSafeQueue&) = delete;

ThreadSafeQueue& operator=(const ThreadSafeQueue&) = delete;bool IsEmpty() const{

MutexLockGuard lk(mMutex);returnmQueue.empty();

}void WaitAndPop(Ty&value)

{

MutexUniqueLock lk(mMutex);

mConVar.wait(lk, [this] {return !mQueue.empty();

});

value=mQueue.front();

mQueue.pop();

}

SharedPtr WaitAndPop()

{

MutexUniqueLock lk(mMutex);

mConVar.wait(lk, [this] {return !mQueue.empty();

});

SharedPtr sp= std::make_shared(mQueue.front());

mQueue.pop();returnsp;

}bool TryPop(Ty&value)

{

MutexLockGuard lk(mMutex);if (mQueue.empty())return false;

value=mQueue.front();

mQueue.pop();return true;

}

SharedPtr TryPop()

{

MutexLockGuard lk(mMutex);if (mQueue.empty())return false;

SharedPtr sp= std::make_shared(mQueue.front());

mQueue.pop();returnsp;

}void Push(const Ty&value)

{

MutexLockGuard lk(mMutex);

mQueue.push(value);

mConVar.notify_all();

}private:

mutable Mutex mMutex;

ConditionVar mConVar;

Queue mQueue;

};#endif //_THREAD_SAFE_QUEUE_

另一个版本, 使用 shared_ptr 作为成员对队列的性能有很大的提升, 其在push时减少了互斥量持有的时间, 允许其它线程在分配内存的同时,对队列进行其它操作.

template

classThreadSafeQueue

{

typedef std::shared_ptrSharedPtr;

typedef std::queueQueue;

typedef std::shared_ptrSharedPtr;

typedef std::lock_guardMutexLockGuard;

typedef std::unique_lockMutexUniqueLock;public:explicitThreadSafeQueue() {}~ThreadSafeQueue() {}

ThreadSafeQueue(const ThreadSafeQueue&) = delete;

ThreadSafeQueue& operator=(const ThreadSafeQueue&) = delete;bool IsEmpty() const{

MutexLockGuard lk(mMutex);returnmQueue.empty();

}void WaitAndPop(Ty&value)

{

MutexUniqueLock lk(mMutex);

mConVar.wait(lk, [this] {return !mQueue.empty();

});

value= std::move(*mQueue.front());

mQueue.pop();

}

SharedPtr WaitAndPop()

{

MutexUniqueLock lk(mMutex);

mConVar.wait(lk, [this] {return !mQueue.empty();

});

SharedPtr sp=mQueue.front();

mQueue.pop();returnsp;

}bool TryPop(Ty&value)

{

MutexLockGuard lk(mMutex);if (mQueue.empty())return false;

value= std::move(*mQueue.front());

mQueue.pop();return true;

}

SharedPtr TryPop()

{

MutexLockGuard lk(mMutex);if (mQueue.empty())return false;

SharedPtr sp=mQueue.front();

mQueue.pop();returnsp;

}void Push(const Ty&value)

{

SharedPtr p= std::make_shared(value);

MutexLockGuard lk(mMutex);

mQueue.push(p);

mConVar.notify_all();

}private:

mutable Mutex mMutex;

ConditionVar mConVar;

Queue mQueue;

};

std::future

期望(std::future)可以用来等待其他线程上的异步结果, 其实例可以在任意时间引用异步结果.

C++包括两种期望, std::future(唯一期望) 和 std::shared_future(共享期望)

std::future 的实例只能与一个指定事件相关联.

std::shared_future 的实例能关联多个事件, 它们同时变为就绪状态, 并且可以访问与事件相关的任何数据.

在与数据无关的地方，可以使用 std::future 与 std::shared_future 的特化模板.

期望对象本身并不提供同步访问, 如果多个线程要访问一个独立的期望对象, 需要使用互斥体进行保护.

std::packaged_task

std::packaged_task 可包装一个函数或可调用的对象, 并且允许异步获取该可调用对象产生的结果, 返回值通过 get_future 返回的 std::future 对象取得, 其返回的 std::future 的模板类型为 std::packaged_task 模板函数签名中的返回值类型.

std::packaged_task 对象被调用时, 就会调用相应的函数或可调用对象, 将期望置为就绪, 并存储返回值.

std::packaged_task 的模板参数是一个函数签名, 如 int(std::string&, double*), 构造 std::packaged_task 实例时必须传入一个可以匹配的函数或可调用对象, 也可以是隐藏转换能匹配的.

std::packaged_task<:string std::string> task([](std::stringstr) {

std::stringstream stm;

stm<< "tid:" << std::this_thread::get_id() << ", str:" << str <<:endl>

std::cout<

std::this_thread::sleep_for(std::chrono::seconds(1));return std::string("MSG:Hello");

});

std::future<:string> f =task.get_future();

std::thread t(std::move(task), std::string("package task test"));

t.detach();//调用 f.get 返回结果, 但是须阻塞等到任务执行完成

std::cout << "main tid:" << std::this_thread::get_id() << ", result:" << f.get() << std::endl;

std::promise

std::promise 类型模板提供设置异步结果的方法, 这样其他线程就可以通过 std::future 实例来索引该结果.

classSquareRoot

{

std::promise&prom;public:

SquareRoot(std::promise&p) : prom(p) {}~SquareRoot() {}void operator()(doublex)

{if (x < 0)

{

prom.set_exception(std::make_exception_ptr(std::out_of_range("x<0")));

}else{double result =std::sqrt(x);

prom.set_value(result);

}

}

};

std::promiseprom;

SquareRoot p(prom);

std::thread t(std::bind(&SquareRoot::operator(), &p, 1));//std::thread t(std::bind(&SquareRoot::operator(), &p, -1));

std::future f =prom.get_future();try{double v = f.get();

std::cout<< "value:" << v <<:endl>

}catch (std::exception&e)

{

std::cout<< "exception:" << e.what() <<:endl>

}

t.join();

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/267537.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

iOS 动画基础总结篇

iOS 动画基础总结篇

iOS 动画基础总结篇 动画的大体分类(个人总结可能有误) 分类.png UIView 动画 属性动画 12345678910111213141516171819[UIView beginAnimations:nil context:nil];[UIView setAnimationDelay:1];[UIView setAnimationDuration:2];[UIView setAnimationRepeatCount:100];[UIVie…
阅读更多...
最老程序员创业札记：全文检索、数据挖掘、推荐引擎应用41

最老程序员创业札记：全文检索、数据挖掘、推荐引擎应用41

入局在北京初冬寒风的吹拂下&#xff0c;吴言渐渐清醒了起来&#xff0c;他现在需要做的是赶紧想办法应付下周赵海波要召开的会议&#xff0c;而不是无谓的生气。吴言走在冬日的街头&#xff0c;一边走一边想。下周的事情还真不少&#xff0c;第一件事是赵海波要召开的公司改组…
阅读更多...
bootstraptable获得所有行_郎酒领衔，2020“川酒全国行”首站香满花城

bootstraptable获得所有行_郎酒领衔，2020“川酒全国行”首站香满花城

12月8日&#xff0c;2020“川酒全国行”首站在广州开启。以“川酒金花醉美珠江”为主题&#xff0c;本次活动由四川省经济和信息化厅指导&#xff0c;四川中国白酒金三角酒业协会主办&#xff0c;四川郎酒股份有限公司承办&#xff0c;五粮液、泸州老窖、剑南春、舍得、水井坊协…
阅读更多...
判断DataRow中某列是否为空的方法

判断DataRow中某列是否为空的方法

DataRow drdt.Rows[0]; if(!dr.IsNull("列名")) { //不为空的操作 }转载于:https://www.cnblogs.com/12go/archive/2011/10/09/2203606.html
阅读更多...
centos7根据端口查进程_记录一次CentOs7下Nginx+WSGI部署Django项目（超详细）

centos7根据端口查进程_记录一次CentOs7下Nginx+WSGI部署Django项目（超详细）

记录一次Django部署的文章&#xff0c;不是很熟悉Linux系统&#xff0c;踩了不少坑&#xff0c;本篇文章相当于是一个总结&#xff0c;我会在本文中详细介绍&#xff0c;部署单个Django项目和多个Django的方法&#xff0c;如读者有更好的方法&#xff0c;欢迎留言一起探讨~长话…
阅读更多...
淘宝跨域获取Cookie分析

淘宝跨域获取Cookie分析

最近在发现使用Taobao的时候的一个小细节&#xff0c;于是便萌发起了写这篇文章。 当我们在 www.taobao.com 中进行登录之后&#xff0c;然后直接切换到 www.tmall.com 域名下&#xff0c;发现www.tmall.com首页的最顶部马上显示成了&#xff1a; 您好, andyfaces。 首先&#…
阅读更多...
mqtt 传文件断开连接的原因_MQTT PythonClient断开连接不当

mqtt 传文件断开连接的原因_MQTT PythonClient断开连接不当

MikeScotty的回答不对。缺少的是启动MQTT网络循环。需要启动循环来处理发送keep-alive包、为QoS 1/2消息进行多段握手以及处理传入的订阅。在如果你只想保持联系或者10秒钟&#xff0c;那么这样的方法就可以了import paho.mqtt.client as mqttimport timeBroker "192.168…
阅读更多...
JAVA方法 字符串与unicode的相互转换

JAVA方法 字符串与unicode的相互转换

unicode编码简而言之就是将每一个字符用16位2进制数标识。但是通常都用4位的16进制数标识。例如&#xff1a;1)中文字符串"你好"的unicode码为&#xff1a;\u<?XML:NAMESPACE PREFIX ST1 />4f60\u597d; 2)英文字符串"ab"的unicode码为&#xff1a;…
阅读更多...
js原型和原型链

js原型和原型链

我们要理解js的原型&#xff0c;首先需要知道5条js原型规则&#xff1a; 1.js引用类型(function ,array ,object)都可以任意扩展自己的属性。 1 function fn(){2 3 }4 fn.age10;5 console.log(fn.age);//106 7 var arr[1,2,3];8 arr.namekeke;9 console.log(arr);//[1,2,3,name…
阅读更多...
solaris 10安装Oracle10.2g

solaris 10安装Oracle10.2g

1> 检查相关的安装包 官方要求的包: SUNWarc SUNWbtool SUNWhea SUNWlibm SUNWlibms SUNWsprot SUNWtoo SUNWi1of SUNWi1cs SUNWi15cs SUNWxwfnt 执行命令 bash-3.00# pkginfo -i SUNWarc SUNWbtool SUNWhea SUNWlibm SUNWlibms SUNWsprot SUNWsprox SUNWtoo SUNWi1of SUNW…
阅读更多...
蜡笔小新里的钢达姆机器人怎么画_写字机器人好用吗？ 组装就花了5个小时 还要学习软件、录入字体...

蜡笔小新里的钢达姆机器人怎么画_写字机器人好用吗？ 组装就花了5个小时 还要学习软件、录入字体...

据江苏公共新闻频道《新闻360》报道&#xff1a;新学期开学&#xff0c;各种各样的课后作业成了孩子和家长关注的话题。前不久&#xff0c;一条“孩子购买代写作业机器人&#xff0c;被家长发现”的新闻&#xff0c;引发了强烈争议。这种可以写字的机器人到底是什么&#xff1f…
阅读更多...
20165235 Java第一周学习总结

20165235 Java第一周学习总结

(# 20165235 Java第一周学习总结 Ubuntu下git的安装与使用首先Ubuntu下git的安装&#xff0c;使用sudo apt-get install git下载Ubuntu,下载完成后可以用指令git查看。 安装完git之后输入git config --global user.name "名字"&#xff0c;git config --global user.…
阅读更多...
解决opencv在pycharm中无代码自动提示的bug

解决opencv在pycharm中无代码自动提示的bug

2018-03-0422:19:39 首先&#xff0c;估计这不是bug 可能是我自己误操作导致的&#xff0c;但是让我搞了好久才搞定&#xff0c;实在是苦恼 如图已实现功能&#xff0c;百度里有很多朋友出现了&#xff0c;这个无代码提示的问题 大概是这样的&#xff0c;毕竟&#xff0c;软件这…
阅读更多...
eBay：PayPal今年移动支付总额将超35亿美元

eBay：PayPal今年移动支付总额将超35亿美元

北京时间10月18日早间消息&#xff0c;eBay(微博) CEO约翰多诺霍(John Donahoe)周一在旧金山的Web 2.0峰会上表示&#xff0c;通过移动设备&#xff0c;PayPal今年处理的总支付额将超过35亿美元。 多诺霍此前曾预计&#xff0c;PayPal今年通过移动设备的总支付额为30亿美元&…
阅读更多...
看风水用什么罗盘最好_兰花用什么花盆栽植最好？

看风水用什么罗盘最好_兰花用什么花盆栽植最好？

兰花用什么花盆栽植最好&#xff1f;高低深浅如何选&#xff1f;文&#xff1a;花木君经常有兰友咨询关于兰花的花盆的问题&#xff0c;诸如用浅盆还是深盆&#xff0c;用什么材质的花盆适宜之类&#xff0c;由于品种不同&#xff0c;兰丛大小各异&#xff0c;如果泛泛的回答&a…
阅读更多...
Shell 示例：利用 $RANDOM 产生随机整数

Shell 示例：利用 $RANDOM 产生随机整数

代码如下&#xff1a; #!/bin/bash# $RANDOM 在每次调用的时候&#xff0c;返回一个不同的随机整数 # 指定的范围是: 0 - 32767 MAXCOUNT10 count1echo echo "$MAXCOUNT random numbers:" echo "-----------------"while [ "$count" -le $MAXCOU…
阅读更多...
发布到服务器接口404_接口测试怎么做？

发布到服务器接口404_接口测试怎么做？

上一期咱们讲到如何使用咱们的龙测工具实现黑盒测试这不&#xff0c;接口也来啦实验步骤抢先看1&#xff0e;首先确定接口的结构&#xff0c;以龙测登录为例请求方式&#xff1a;POSTURL&#xff1a;https://prod.dragontesting.com/api/login请求体&#xff1a;包含两个必填参…
阅读更多...
畅通工程 HDU - 1863

畅通工程 HDU - 1863

省政府“畅通工程”的目标是使全省任何两个村庄间都可以实现公路交通&#xff08;但不一定有直接的公路相连&#xff0c;只要能间接通过公路可达即可&#xff09;。经过调查评估&#xff0c;得到的统计表中列出了有可能建设公路的若干条道路的成本。现请你编写程序&#xff0c;…
阅读更多...
SoftReference和WeakReference

SoftReference和WeakReference

Java2增强了内存管理功能&#xff0c; 增加了一个java.lang.ref包&#xff0c;其中定义了三种引用类。这三种引用类分别为SoftReference、WeakReference和PhantomReference.通过使用这些引用类&#xff0c;程序员可以在一定程度与GC进行交互&#xff0c;以便改善GC的工作效率。…
阅读更多...
docker ubuntu 文件同步_Docker 的数据管理--Docker从入门到精通摘记

docker ubuntu 文件同步_Docker 的数据管理--Docker从入门到精通摘记

Docker 数据管理用户在使用 Docker 的过程中&#xff0c;‍‍往往需要能够查看容器内应用产生的数据&#xff0c;‍‍或者说‍‍需要把容器内的数据进行备份&#xff0c;‍‍再或者说‍‍多个容器之间需要进行数据的共享&#xff0c;‍‍那么这些就必然涉及到容器的数据管理操作…
阅读更多...
最新文章

Copyright @ 2022~2023