阻塞队列通过互斥锁和条件变量实现线程安全的生产者-消费者模型，支持固定容量下的阻塞插入与提取，适用于任务调度与线程间通信。
在C++多线程编程中，阻塞队列是线程间通信的常用工具。它允许一个或多个生产者线程向队列添加数据，同时一个或多个消费者线程从队列获取数据。当队列为空时，消费者线程会被阻塞，直到有新数据进入；当队列满时（如果是有界队列），生产者线程也会被阻塞，直到有空间可用。
使用标准库实现阻塞队列
借助 std::queue、std::mutex、std::condition_variable 和 std::unique_lock，可以轻松实现一个线程安全的阻塞队列。
示例代码：
#include #include #include #include #include templateclass BlockingQueue {private: std::queue 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 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 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 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 lock(mtx); return data_queue.empty(); } size_t size() const { std::lock_guard lock(mtx); return data_queue.size(); }};
多线程通信场景中的使用方式
阻塞队列常用于生产者-消费者模型。以下是一个简单示例，展示两个线程如何通过阻塞队列通信。
int main() { BlockingQueue 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 标志位，支持优雅关闭队列，唤醒所有等待线程。
基本上就这些。只要理解了互斥锁和条件变量的协作机制，阻塞队列的实现并不复杂，但非常实用。
以上就是c++++ 怎么实现一个阻塞队列_c++多线程通信与阻塞队列实现方法的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1484688.html
微信扫一扫 
支付宝扫一扫 
