c++11baohan线程安全的队列
2015-11-27 22:44
591 查看
#include "stdafx.h" #include <queue> #include <mutex> #include <condition_variable> #include <memory> template<class T> class threadsafe_queue { private: mutable std::mutex mut; std::queue<std::shared_ptr<T>> data_queue; std::condition_variable data_con; public: threadsafe_queue(){} threadsafe_queue(threadsafe_queue const& other) { std::lock_guard<std::mutex> lk(other.mut); data_queue = other.data_queue; } void push(T tValue) { std::shared_ptr<T> data(std::make_shared<T>(std::move(tValue))); std::lock_guard<std::mutex> lk(mut); data_queue.push(data); data_con.notify_one(); } void wait_and_pop(T& tValue) { std::unique_lock<std::mutex> lk(mut); data_con.wait(lk,[this]{return !data_queue.empty();}); tValue = std::move(*data_queue.front()); data_queue.pop(); } std::shared_ptr<T>wait_and_pop() { std::unique_lock<std::mutex> lk(mut); data_con.wait(lk,[this]{return !data_queue.empty();}); std::shared_ptr<T> ret (std::make_shared<T>(data_queue.front())); data_queue.pop(); return ret; } bool try_pop(T& tValue) { std::lock_guard<std::mutex> lk(mut); if(data_queue.empty()) return false; tValue = std::move(*data_queue.front()); data_queue.pop(); return true; } std::shared_ptr<T> try_pop() { std::lock_guard<std::mutex> lk(mut); if(data_queue.empty()) return std::shared_ptr<T>(); std::shared_ptr<T> ret(std::make_shared(data_queue.front())); data_queue.pop(); return ret; } bool empty() const { std::lock_guard<std::mutex> lk(mut); return data_queue.empty(); } };
相关文章推荐
- 使用C++实现JNI接口需要注意的事项
- 关于指针的一些事情
- c++ primer 第五版 笔记前言
- share_ptr的几个注意点
- boost相关小知识(长期顶置更新)
- C#线程间不能调用剪切板的解决方法
- Lua中调用C++函数示例
- Lua教程(一):在C++中嵌入Lua脚本
- Lua教程(二):C++和Lua相互传递数据示例
- C#线程同步的三类情景分析
- C#获取进程或线程相关信息的方法
- C#停止线程的方法
- C#子线程更新UI控件的方法实例总结
- C#线程队列用法实例分析
- C++联合体转换成C#结构的实现方法
- C++编写简单的打靶游戏
- C++ 自定义控件的移植问题
- C++变位词问题分析
- C/C++数据对齐详细解析
- C++基于栈实现铁轨问题