muduo：BoundedBlockingQueue支持多生产者多生产者消费者模式式么

来源：蜘蛛抓取(WebSpider) 时间：2016-12-16 04:14 标签： 生产者和消费者模式
众鑫娱乐手机版-众鑫娱乐手机版_
||在线反馈
众鑫娱乐手机版
请选择省份
购车月份未选择
免费体验会员违章提醒服务《用户协议》
快速查询：（点击车牌号直接查询）
最近查询 全国车辆的交通违章记录情况
车牌号码 违章行为 违章地点
违章时间 罚款金额 扣分
粤B4E***驾驶中型以上载客载货汽车、危险物品运输车辆以外的其他机动车行驶超过规定时速10%未达20%的【广东惠州】潮莞高速西行30公里900米 13:36:58150元3粤SQ8***驾驶中型以上载客载货汽车、校车、危险物品运输车辆以外的其他机动车行驶超过规定时速20%以上未达到50%的【湖南永州】G207国道江华瑶族自治县K2922 12:49:11150元6粤SQ8***驾驶中型以上载客载货汽车、校车、危险物品运输车辆以外的其他机动车行驶超过规定时速20%以上未达到50%的【湖南永州】G207国道江华瑶族自治县K2922 13:57:06150元6粤SQ8***机动车违反规定停放、临时停车，妨碍其它车辆、行人通行的【广东东莞】中心路（流动抓拍） 8:38:00200元0鲁BM7***不按规定停车消防通道 14:24:00100元0鲁BM7***逆向行驶海王路与凰蹲山路路口 0:11:24200元3粤AU5***机动车违反规定停放、临时停车，妨碍其它车辆、行人通行的【广东广州】广州市海珠区新港中路_广州市海珠区新港中路路段 20:35:00200元0粤A6S***机动车违反规定停放、临时停车，妨碍其它车辆、行人通行的【广东广州】穗福街_穗福街 15:02:00200元0粤A6S***机动车违反规定停放、临时停车，妨碍其它车辆、众鑫娱乐手机版、行人通行的【广东广州】穗福街_穗福街 15:02:00200元0鲁P92***违反信号灯规定建设路卫育路口 9:48:00200元6皇家国际_皇家国际_【添运铺子】君，已阅读到文档的结尾了呢~~
muduo 网络库使用手册 陈硕 1 muduo 网络库使用手册
扫扫二维码，随身浏览文档
手机或平板扫扫即可继续访问
muduo 网络库使用手册 陈硕 1 muduo 网络库使用手册
举报该文档为侵权文档。
举报该文档含有违规或不良信息。
反馈该文档无法正常浏览。
举报该文档为重复文档。
推荐理由：
将文档分享至：
分享完整地址
文档地址：
粘贴到BBS或博客
flash地址：
支持嵌入FLASH地址的网站使用
html代码：
&embed src='/DocinViewer--144.swf' width='100%' height='600' type=application/x-shockwave-flash ALLOWFULLSCREEN='true' ALLOWSCRIPTACCESS='always'&&/embed&
450px*300px480px*400px650px*490px
支持嵌入HTML代码的网站使用
您的内容已经提交成功
您所提交的内容需要审核后才能发布，请您等待！
3秒自动关闭窗口Muduo里的blockingQueue实现线程池伪码
Muduo里的blockingQueue实现线程池伪码
#include &muduo/base/Condition.h&
#include &muduo/base/Mutex.h&
#include &boost/noncopyable.hpp&
#include &deque&
#include &assert.h&
template&typename T&
class BlockingQueue : boost::noncopyable
BlockingQueue(): mutex_(),notEmpty_(mutex_),queue_(){}
void put(const T& x)
MutexLockGuard lock(mutex_);//安全加锁pthread_mutex_t
queue_.push_back(x);
notEmpty_.notify(); // wait morphing saves us
// /blog/computing/condvars-signal-with-mutex-locked-or-not/
MutexLockGuard lock(mutex_);
// always use a while-loop, due to spurious wakeup
while (queue_.empty())
notEmpty_.wait();
assert(!queue_.empty());
T front(queue_.front());
queue_.pop_front();
size_t size() const
MutexLockGuard lock(mutex_);
return queue_.size();
mutable MutexLock mutex_;//pthread_mutex_t的封装
notEmpty_;//pthread_cond_t的封装
std::deque&T&
//用阻塞对咧咧实现任务队列
typedef boost::function&void()& F
BlockingQueue&Functor& taskQ//线程安全的阻塞队列
void workThread(){
while(running){
Functor task=taskQueue.take();
task();//考虑异常处理
int N=num_of_computing_
for(int i=0;i&N;i++){
create_thread(&workThread);//启动线程
boost::function&void()& task=boost::bind(&Foo::calc,&foo);
taskQueue.post(task);
我的热门文章
即使是一小步也想与你分享

我要回帖

更多关于 生产者和消费者模式 的文章

 

随机推荐