c++如何实现一个阻塞队列 c++生产者消费者模型【实例】

什么是阻塞队列

阻塞队列是一种线程安全的队列，当队列为空时，消费者线程调用 pop() 会自动等待，直到有新元素入队；当队列为满时（如有容量限制），生产者线程调用 push() 也会等待，直到有空位。这种“自动等待+唤醒”机制，天然适配生产者-消费者模型。

核心实现要点

要用 C++ 实现一个可靠的阻塞队列，需结合以下三要素：

• std::queue 或 std::deque 作为底层容器（推荐 deque，支持高效首尾操作）
• std::mutex 保护共享数据，防止多线程并发访问冲突
• std::condition_variable 实现线程挂起与唤醒：一个用于“非空”通知（消费者等数据），一个用于“非满”通知（生产者等空间）——若无容量限制，可只用一个条件变量

无界阻塞队列示例（常用场景）

下面是一个简洁、可直接运行的无界阻塞队列实现（支持 move 语义，线程安全）：

#include 
#include 
#include 
#include 
template 
class BlockingQueue {
private:
std::queue queue;
mutable std::mutex mtx;
std::condition_variable notempty;
std::condition_variable notfull; // 可选，无界时仅作占位
public:
void push(T item) {
std::uniquelock lock(mtx);
queue_.push(std::move(item));
notempty.notify_one(); // 唤醒等待消费的线程
}
T pop() {
    std::unique_lockzuojiankuohaophpcnstd::mutexyoujiankuohaophpcn lock(mtx_);
    not_empty_.wait(lock, [this] { return !queue_.empty(); });
    T item = std::move(queue_.front());
    queue_.pop();
    return item;
}

// 带超时的 pop（避免永久阻塞）
bool pop(T& item, std::chrono::milliseconds timeout) {
    std::unique_lockzuojiankuohaophpcnstd::mutexyoujiankuohaophpcn lock(mtx_);
    if (not_empty_.wait_for(lock, timeout, [this] { return !queue_.empty(); })) {
        item = std::move(queue_.front());
        queue_.pop();
        return true;
    }
    return false;
}

bool empty() const {
    std::unique_lockzuojiankuohaophpcnstd::mutexyoujiankuohaophpcn lock(mtx_);
    return queue_.empty();
}
};
生产者-消费者完整实例
用上面的 BlockingQueue 启动多个生产者和消费者线程，模拟真实协作：
#include 
#include 
#include 
#include 
BlockingQueue bq;
void producer(int id, int count) {
for (int i = 0; i < count; ++i) {
int val = id * 100 + i;
bq.push(val);
std::cout << "[P" << id << "] pushed " << val << "\n";
std::this_thread::sleep_for(std::chrono::milliseconds(100));
}
}
void consumer(int id) {
while (true) {
int val;
if (bq.pop(val, std::chrono::milliseconds(500))) {
std::cout << "[C" << id << "] consumed " << val << "\n";
} else {
std::cout << "[C" << id << "] timeout, exiting...\n";
break;
}
}
}
int main() {
std::vector producers, consumers;
// 启动 2 个生产者，各发 3 个数
for (int i = 0; i zuojiankuohaophpcn 2; ++i) {
    producers.emplace_back(producer, i, 3);
}

// 启动 3 个消费者
for (int i = 0; i zuojiankuohaophpcn 3; ++i) {
    consumers.emplace_back(consumer, i);
}

for (auto& t : producers) t.join();
for (auto& t : consumers) t.join();

return 0;
}
编译运行时加 -std=c++17 -pthread。输出会交错显示生产和消费过程，体现线程间自然同步。
注意事项与优化建议
实际工程中还需考虑：

若需有界队列，构造时传入最大容量，在 push() 中检查并用 not_full_.wait() 阻塞
增加 stop() 接口配合 std::atomic_bool 实现优雅退出（避免消费者无限等待）
对频繁操作场景，可用 std::deque 替代 std::queue 获得更好缓存局部性
避免在锁内做耗时操作（如 I/O、复杂计算），保持临界区尽量短
 
		


# ai 
# c++ 
# ios 
# stream 
# 并发访问 
# int 
# 接口 
# 线程 
# 多线程 
# 并发 
# 无界 
# 是一个 
# 是一种 
# 也会 
# 多个 
# 如有 
# 要用 
# 可选 
# 可直接 
# 最大容量 
 




相关文章：
 潮流网站制作头像软件下载,适合母子的网名有哪些？ 
如何快速上传自定义模板至建站之星？ 
 制作销售网站教学视频,销售网站有哪些？ 
如何在七牛云存储上搭建网站并设置自定义域名？ 
香港服务器租用每月最低只需15元？ 
如何选择建站程序？包含哪些必备功能与类型？ 
c# F# 的 MailboxProcessor 和 C# 的 Actor 模型 
如何用IIS7快速搭建并优化网站站点？ 
如何用好域名打造高点击率的自主建站？ 
 活动邀请函制作网站有哪些,活动邀请函文案？ 
如何在阿里云购买域名并搭建网站？ 
建站之星代理如何优化在线客服效率？ 
 单页制作网站有哪些,朋友给我发了一个单页网站，我应该怎么修改才能把他变成自己的呢，请求高手指点迷津？ 
 股票网站制作软件,网上股票怎么开户？ 
如何自定义建站之星网站的导航菜单样式？ 
如何选择香港主机高效搭建外贸独立站？ 
建站主机核心功能解析：服务器选择与网站搭建流程指南 
如何通过主机屋免费建站教程十分钟搭建网站？ 
 网站制作免费,什么网站能看正片电影？ 
 淘宝制作网站有哪些,淘宝网官网主页？ 
 品牌网站制作公司有哪些,买正品品牌一般去哪个网站买？ 
如何选择域名并搭建高效网站？ 
 模具网站制作流程,如何找模具客户？ 
如何用花生壳三步快速搭建专属网站？ 
如何高效搭建专业期货交易平台网站？ 
 上海网站制作网站建设公司,建筑电工证网上查询系统入口？ 
如何通过FTP空间快速搭建安全高效网站？ 
 深圳网站制作费用多少钱,读秀，深圳文献港这样的网站很多只提供网上试读，但有些人只要提供试读的文章就能全篇下载，这个是怎么弄的？ 
小型网站建站如何选择虚拟主机？ 
 成都品牌网站制作公司,成都营业执照年报网上怎么办理？ 
Swift开发中switch语句值绑定模式 
 音响网站制作视频教程,隆霸音响官方网站？ 
 武汉外贸网站制作公司,现在武汉外贸前景怎么样啊？ 
实例解析Array和String方法 
香港服务器网站生成指南：免费资源整合与高速稳定配置方案 
 公司网站制作价格怎么算,公司办个官网需要多少钱？ 
 专业网站设计制作公司,如何制作一个企业网站，建设网站的基本步骤有哪些？ 
孙琪峥织梦建站教程如何优化数据库安全？ 
如何获取免费开源的自助建站系统源码？ 
如何在万网主机上快速搭建网站？ 
建站中国官网：模板定制+SEO优化+建站流程一站式指南 
 制作网页的网站有哪些,电脑上怎么做网页？ 
建站之星如何保障用户数据免受黑客入侵？ 
如何高效利用亚马逊云主机搭建企业网站？ 
建站主机助手选型指南：2025年热门推荐与高效部署技巧 
建站主机系统SEO优化与智能配置核心关键词操作指南 
建站主机CVM配置优化、SEO策略与性能提升指南 
 网站制作公司排行榜,四大门户网站排名？ 
如何在自有机房高效搭建专业网站？ 
 动图在线制作网站有哪些,滑动动图图集怎么做？