阻塞队列通过互斥锁和条件变量实现线程安全的生产者-消费者模型，支持固定容量下的阻塞插入与提取，适用于任务调度与线程间通信。
在C++多线程编程中，阻塞队列是线程间通信的常用工具。它允许一个或多个生产者线程向队列添加数据，同时一个或多个消费者线程从队列获取数据。当队列为空时，消费者线程会被阻塞，直到有新数据进入；当队列满时（如果是有界队列），生产者线程也会被阻塞，直到有空间可用。
使用标准库实现阻塞队列
借助 std::queue、std::mutex、std::condition_variable 和 std::unique_lock，可以轻松实现一个线程安全的阻塞队列。
示例代码：
#include <queue>
#include <mutex>
#include <condition_variable>
#include <thread>
#include <iostream>
template<typename T>
class BlockingQueue {
private:
std::queue<T> data_queue;
mutable std::mutex mtx;
std::condition_variable not_empty;
std::condition_variable not_full;
size_t max_size;
public:
explicit BlockingQueue(size_t max_sz = 1000) : max_size(max_sz) {}
void push(const T& item) {
std::unique_lock<std::mutex> lock(mtx);
not_full.wait(lock, [this] { return data_queue.size() < max_size; });
data_queue.push(item);
not_empty.notify_one();
}
void pop(T& item) {
std::unique_lock<std::mutex> lock(mtx);
not_empty.wait(lock, [this] { return !data_queue.empty(); });
item = data_queue.front();
data_queue.pop();
not_full.notify_one();
}
bool try_pop(T& item) {
std::unique_lock<std::mutex> lock(mtx);
if (data_queue.empty()) {
return false;
}
item = data_queue.front();
data_queue.pop();
not_full.notify_one();
return true;
}
bool empty() const {
std::lock_guard<std::mutex> lock(mtx);
return data_queue.empty();
}
size_t size() const {
std::lock_guard<std::mutex> lock(mtx);
return data_queue.size();
}
};
多线程通信场景中的使用方式
阻塞队列常用于生产者-消费者模型。以下是一个简单示例，展示两个线程如何通过阻塞队列通信。
int main() {
BlockingQueue<int> queue(5); // 最多容纳5个元素
std::thread producer([&]() {
for (int i = 0; i < 10; ++i) {
queue.push(i);
std::cout << "生产: " << i << "\n";
}
});
std::thread consumer([&]() {
for (int i = 0; i < 10; ++i) {
int value;
queue.pop(value);
std::cout << "消费: " << value << "\n";
}
});
producer.join();
consumer.join();
return 0;
}
关键点说明与建议
实现阻塞队列时需要注意几个核心机制：
立即学习“C++免费学习笔记（深入）”；
- 条件变量等待必须用循环或 wait 的谓词形式：防止虚假唤醒导致问题。
- 每次修改队列前必须加锁：保证对 queue 的操作是原子的。
- 通知机制要正确触发：push 后 notify not_empty，pop 后 notify not_full。
- 可选支持 try_pop 或超时 pop：提高灵活性，避免无限等待。
如果需要无界队列，可以去掉 max_size 限制和 not_full 条件变量，只保留 not_empty 即可。
应用场景与扩展思路
阻塞队列广泛应用于任务调度、日志系统、消息中间件等场景。
- 可用于线程池中任务队列的实现。
- 结合 shared_ptr 支持对象传递，避免拷贝开销。
- 增加 shutdown 标志位，支持优雅关闭队列，唤醒所有等待线程。
基本上就这些。只要理解了互斥锁和条件变量的协作机制，阻塞队列的实现并不复杂，但非常实用。
