C++实现阻塞队列

#ifndef BLCOKING_QUEUE_H
#define BLCOKING_QUEUE_H

#include 
#include 
#include 
#include 

template
class BlockingQueue {
public:
	BlockingQueue() = default;
	BlockingQueue(size_t maxSize) : maxSize_(maxSize) {}
	BlockingQueue(const BlockingQueue&) = default;

	 bool Pop(T& t) {
		std::unique_lock lock(mutex_);
		conditionVar_.wait(lock, [this]() { return !queue_.empty() || isStop_; });
		if (isStop_) {
			return false;
		}
		t = queue_.front();
		queue_.pop_front();
		conditionVar_.notify_one();
		return true;
	}

	bool Push(T elem) {
		std::unique_lock lock(mutex_);
		conditionVar_.wait(lock, [this]() { return (queue_.size() < maxSize_) || isStop_; });
		if (isStop_) {
			return false;
		}
		queue_.push_back(elem);
		conditionVar_.notify_one();
		return true;
	}

	void SetMaxSize(int size) {
		maxSize_ = size;
	}

	void Notify() {
		{
			std::unique_lock lock(mutex_);
			isStop_ = true;
		}
		conditionVar_.notify_all();
	}

	void Stop() {
		{
			std::unique_lock lock(mutex_);
			isStop_ = true;
		}
		conditionVar_.notify_all();
		queue_.clear();
	}

	void Start() {
		std::unique_lock lock(mutex_);
		isStop_ = false;
	}

	bool Empty() {
		std::unique_lock lock(mutex_);
		return queue_.empty();
	}

	size_t Size() {
		std::unique_lock lock(mutex_);
		return queue_.size();
	}

private:
	bool isStop_ = false;
	std::mutex mutex_;
	std::condition_variable conditionVar_;
	std::list queue_;
	size_t maxSize_ = 10;
};

#endif