c/c++ 利用条件变量(Condition variable)简单实现一个线程安全的队列(源码分享)
时间:2018-11-19
本文章向大家介绍c/c++ 利用条件变量(Condition variable)简单实现一个线程安全的队列,需要的朋友可以参考一下
多线程 利用条件变量实现线程安全的队列
背景:标准STL库的队列queue是线程不安全的。
利用条件变量(Condition variable)简单实现一个线程安全的队列。
代码:
#include <queue>
#include <memory>
#include <mutex>
#include <condition_variable>
#include <iostream>
#include <thread>
template<typename T>
class threadsave_queue{
private:
mutable std::mutex mut;//必须是mutable,因为empty是const方法,但是要锁mut,锁操作就是改变操作
std::queue<T> data_queue;
std::condition_variable data_cond;
public:
threadsave_queue(){}
threadsave_queue(threadsave_queue const& other){
std::lock_guard<std::mutex> lk(other.mut);
data_queue = other.data_queue();
}
void push(T new_value){
std::lock_guard<std::mutex> lk(mut);
data_queue.push(new_value);
data_cond.notify_one();
}
void wait_and_pop(T& value){
std::unique_lock<std::mutex> lk(mut);
data_cond.wait(lk, [this]{return !data_queue.empty();});
value = data_queue.front();
data_queue.pop();
}
std::shared_ptr<T> wait_and_pop(){
std::unique_lock<std::mutex> lk(mut);
data_cond.wait(lk, [this]{return !data_queue.empty();});
std::shared_ptr<T> res(std::make_shared<T>(data_queue.front()));
data_queue.pop();
return res;
}
bool empty()const{
std::lock_guard<std::mutex> lk(mut);
return data_queue.empty();
}
};
void make_data(threadsave_queue<int>& tq, int val){
tq.push(val);
}
void get_data1(threadsave_queue<int>& tq, int& d1){
tq.wait_and_pop(d1);
}
void get_data2(threadsave_queue<int>& tq, int& d1){
auto at = tq.wait_and_pop();
d1 = *at;
}
int main(){
threadsave_queue<int> q1;
int d1;
std::thread t1(make_data, std::ref(q1), 10);
std::thread t2(get_data1, std::ref(q1),std::ref(d1));
t1.join();
t2.join();
std::cout << d1 << std::endl;
std::thread t3(make_data, std::ref(q1), 20);
std::thread t4(get_data2, std::ref(q1),std::ref(d1));
t3.join();
t4.join();
std::cout << d1 << std::endl;
q1.empty();
}
编译方法:
g++ -g XXX.cpp -std=c++11 -L/home/ys/Downloads/boost_1_68_0/stage/lib -lboost_thread -lboost_system -pthread
编译或者运行有问题的,请参考多线程 boost编译与运行的坑
- live writer的折腾
- 用C语言写的万年历---亲手写的。好累哦
- Flash/Flex学习笔记(32):播放音乐并同步显示lyc歌词(适用于Silverlight)
- Flash/Flex学习笔记(31):对象拖拽与投掷
- 如何评价张小龙在2016微信公开课的演讲
- VS2010如何做WAP开发
- (原创)详解KMP算法
- Flash/Flex学习笔记(30):不用startDrag和stopDrag的对象拖动
- JS代码和网页的混用
- Flash/Flex学习笔记(29):MovieClip帧/时间轴的控制
- Oracle日常运维操作总结-数据库的启动和关闭
- Python中Json解析的坑
- Flash/Flex学习笔记(28):动态文本的滚动控制
- CentOS7下Elasticsearch集群部署记录
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- 推荐算法之: DeepFM及使用DeepCTR测试
- Cypress系列(61)- 断言最佳实践
- Cypress系列(62)- 改造 PageObject 模式
- CPU 执行程序的秘密,藏在了这 15 张图里
- Cypress系列(63)- 使用 Custom Commands
- Python字符串操作大全
- Cypress系列(64)- 数据驱动策略
- 别只会搜日志了,求你懂点原理吧
- Cypress系列(65)- 测试运行失败自动重试
- CentOS7下编译FFMPEG源代码
- Android 的 Presentation 双屏异显,遇到的问题总结
- 音视频相关开发库和资料
- Flink深入浅出: 应用部署与原理图解(v1.11)
- 用 Github Actions 在 K8S 中运行 CI 测试
- 线程池的拒绝策略