您当前的位置: 首页 >  c++

鱼儿-1226

暂无认证

  • 0浏览

    0关注

    1100博文

    0收益

  • 0浏览

    0点赞

    0打赏

    0留言

私信
关注
热门博文

用C++11实现一个有界的阻塞队列

鱼儿-1226 发布时间:2020-09-30 10:59:00 ,浏览量:0

对于一个无界的阻塞队列而言,其实现非常简单,即用一个锁(锁队列)+ 一个条件变量(判空)即可。那么对于一个有界阻塞队列而言,其队列的容量有上限,其实只要再加一个条件变量用来判断是否满即可。 综上,我们需要

  • 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             
关注
打赏
1604459285
查看更多评论
0.0495s