0

0

c++中如何实现生产者消费者模型_c++多线程条件变量应用实例【汇总】

穿越時空

穿越時空

发布时间:2026-01-18 13:15:08

|

229人浏览过

|

来源于php中文网

原创

必须用wait()谓词重载版本防虚假唤醒;notify_all()适用于非独占资源如缓冲区空满;锁须包裹条件检查与操作全过程;条件变量生命周期须长于等待线程。

c++中如何实现生产者消费者模型_c++多线程条件变量应用实例【汇总】

std::mutex + std::condition_variable 实现生产者消费者模型是 C++ 多线程中最典型也最容易出错的实践之一。核心不在于“能不能跑”,而在于“唤醒是否可靠”“边界是否守得住”“虚假唤醒是否被处理”。下面直奔关键点。

为什么必须用 wait() 的谓词重载版本?

直接调用 cv.wait(lock) 是危险的——它不检查条件是否真正满足,只负责挂起和被唤醒。一旦发生虚假唤醒(spurious wakeup),线程会跳过条件判断直接往下执行,导致读空队列或写满队列。

正确做法是始终使用带谓词的重载:cv.wait(lock, [&]{ return !queue.empty(); });

  • 该重载内部自动循环检查谓词,天然防虚假唤醒
  • 谓词必须捕获所有依赖变量(如 queue),且不能抛异常
  • 不要写成 while(queue.empty()) cv.wait(lock); —— 手动 while 容易漏锁或逻辑错位

notify_one() 还是 notify_all()

多数场景下用 notify_one() 更高效,但前提是:你明确知道每次只该唤醒一个等待者。

立即学习C++免费学习笔记(深入)”;

生产者消费者中,常见错误是:

Q.AI视频生成工具
Q.AI视频生成工具

支持一分钟生成专业级短视频,多种生成方式,AI视频脚本,在线云编辑,画面自由替换,热门配音媲美真人音色,更多强大功能尽在QAI

下载
  • 生产者调用 notify_one(),但多个消费者在等——只有一个被唤醒,其余继续挂起,没问题
  • 消费者调用 notify_one(),但多个生产者在等——同理,也 OK
  • 但若队列容量有限(如环形缓冲区),且生产者需等待“有空位”,此时多个生产者可能同时被阻塞;如果只 notify_one,其他生产者永远收不到信号——这时必须用 notify_all()

更稳妥的做法:对“非独占资源”(如缓冲区空/满)统一用 notify_all();对“一对一唤醒”(如任务就绪)可用 notify_one()

如何避免死锁和竞争?

最常踩的坑是锁粒度与条件检查脱节。例如:

std::queue<int> queue;
std::mutex mtx;
std::condition_variable cv;

// ❌ 错误:先检查再加锁,中间存在竞态
if (queue.empty()) {
    std::unique_lock<std::mutex> lock(mtx);
    cv.wait(lock, [&]{ return !queue.empty(); }); // 可能永远等下去
}

// ✅ 正确:锁必须包裹整个条件检查 + wait + 操作
std::unique_lock<std::mutex> lock(mtx);
cv.wait(lock, [&]{ return !queue.empty(); });
int val = queue.front();
queue.pop();
  • 所有对共享数据(queue)的访问,包括 empty()front()pop(),都必须在 std::unique_lock 保护下
  • wait() 内部会自动释放锁,并在唤醒后重新获取——这个机制不能绕过
  • 不要用 std::lock_guard 替代 std::unique_lock,因为 wait() 要求可转移、可释放的锁

要不要用 std::deque无锁结构替代 std::queue

std::queue 默认基于 std::deque,本身不是线程安全的,所以仍需外部同步。换成 std::deque 并不会减少锁需求——只是让你多一层手动管理 push_back()/pop_front() 的麻烦。

真要优化性能,考虑以下路径:

  • 单生产者单消费者(SPSC):可用 boost::lockfree::queue 或自实现环形缓冲区,避开锁
  • 多生产者多消费者(MPMC):标准库无原生支持,moodycamel::ConcurrentQueue 是较成熟选择
  • 但除非压测确认锁是瓶颈,否则别过早替换——std::mutex + std::condition_variable 在现代 glibc/libstdc++ 上已足够高效

真正容易被忽略的是:条件变量的生命周期必须长于所有等待它的线程。如果主线程析构了 cv,而子线程还在 wait(),行为未定义——务必确保同步对象的销毁顺序。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
while的用法
while的用法

while的用法是“while 条件: 代码块”,条件是一个表达式,当条件为真时,执行代码块,然后再次判断条件是否为真,如果为真则继续执行代码块,直到条件为假为止。本专题为大家提供while相关的文章、下载、课程内容,供大家免费下载体验。

106

2023.09.25

线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

765

2023.08.10

Python 多线程与异步编程实战
Python 多线程与异步编程实战

本专题系统讲解 Python 多线程与异步编程的核心概念与实战技巧,包括 threading 模块基础、线程同步机制、GIL 原理、asyncio 异步任务管理、协程与事件循环、任务调度与异常处理。通过实战示例,帮助学习者掌握 如何构建高性能、多任务并发的 Python 应用。

377

2025.12.24

java多线程相关教程合集
java多线程相关教程合集

本专题整合了java多线程相关教程,阅读专题下面的文章了解更多详细内容。

31

2026.01.21

C++多线程相关合集
C++多线程相关合集

本专题整合了C++多线程相关教程,阅读专题下面的的文章了解更多详细内容。

29

2026.01.21

C# 多线程与异步编程
C# 多线程与异步编程

本专题深入讲解 C# 中多线程与异步编程的核心概念与实战技巧,包括线程池管理、Task 类的使用、async/await 异步编程模式、并发控制与线程同步、死锁与竞态条件的解决方案。通过实际项目,帮助开发者掌握 如何在 C# 中构建高并发、低延迟的异步系统,提升应用性能和响应速度。

103

2026.02.06

Python 多线程与异步编程实战
Python 多线程与异步编程实战

本专题系统讲解 Python 多线程与异步编程的核心概念与实战技巧,包括 threading 模块基础、线程同步机制、GIL 原理、asyncio 异步任务管理、协程与事件循环、任务调度与异常处理。通过实战示例,帮助学习者掌握 如何构建高性能、多任务并发的 Python 应用。

377

2025.12.24

java多线程相关教程合集
java多线程相关教程合集

本专题整合了java多线程相关教程,阅读专题下面的文章了解更多详细内容。

31

2026.01.21

C# ASP.NET Core微服务架构与API网关实践
C# ASP.NET Core微服务架构与API网关实践

本专题围绕 C# 在现代后端架构中的微服务实践展开,系统讲解基于 ASP.NET Core 构建可扩展服务体系的核心方法。内容涵盖服务拆分策略、RESTful API 设计、服务间通信、API 网关统一入口管理以及服务治理机制。通过真实项目案例,帮助开发者掌握构建高可用微服务系统的关键技术,提高系统的可扩展性与维护效率。

3

2026.03.11

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
10分钟--Midjourney创作自己的漫画
10分钟--Midjourney创作自己的漫画

共1课时 | 0.1万人学习

Midjourney 关键词系列整合
Midjourney 关键词系列整合

共13课时 | 0.9万人学习

AI绘画教程
AI绘画教程

共2课时 | 0.2万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号