对于一个无界的阻塞队列而言,其实现非常简单,即用一个锁(锁队列)+ 一个条件变量(判空)即可。那么对于一个有界阻塞队列而言,其队列的容量有上限,其实只要再加一个条件变量用来判断是否满即可。 综上,我们需要
- mutex: 保护队列的读写操作
- notEmptyCV: 条件变量,在take时wait, 在put之后notify
- notFullCV: 条件变量, 在put时wait, 在take之后notify.
C++11提供了丰富的多线程编程库,包括加锁解锁、同步原语等封装。我的实现如下:
#pragma once
// Must use it higher than C++11
#include
#include
#include
#include
#include
#include
#include
using namespace std::chrono_literals;
template
class BoundedBlockingQueue {
public:
// make class non-copyable
BoundedBlockingQueue(const BoundedBlockingQueue&) = delete;
BoundedBlockingQueue& operator=(const BoundedBlockingQueue&) = delete;
explicit BoundedBlockingQueue(size_t maxSize)
: mtx_(),
maxSize_(maxSize)
{
}
void put(const T& x) {
// std::cout
关注
打赏
最近更新
- 深拷贝和浅拷贝的区别(重点)
- 【Vue】走进Vue框架世界
- 【云服务器】项目部署—搭建网站—vue电商后台管理系统
- 【React介绍】 一文带你深入React
- 【React】React组件实例的三大属性之state,props,refs(你学废了吗)
- 【脚手架VueCLI】从零开始,创建一个VUE项目
- 【React】深入理解React组件生命周期----图文详解(含代码)
- 【React】DOM的Diffing算法是什么?以及DOM中key的作用----经典面试题
- 【React】1_使用React脚手架创建项目步骤--------详解(含项目结构说明)
- 【React】2_如何使用react脚手架写一个简单的页面?