0

0

c++的std::condition_variable如何实现线程同步? (生产者消费者模型)

裘德小鎮的故事

裘德小鎮的故事

发布时间:2026-01-12 13:28:02

|

325人浏览过

|

来源于php中文网

原创

std::condition_variable必须与std::mutex配合使用,所有共享数据访问及wait/notify操作均需在mutex保护下进行;需用while循环检查条件以应对虚假唤醒;notify_one适用于单消费者场景,notify_all适用于批量生产或多消费者;退出时须设置原子标志并notify_all确保线程安全终止。

c++的std::condition_variable如何实现线程同步? (生产者消费者模型)

std::condition_variable 必须和 std::mutex 一起用

单独声明 std::condition_variable 没有意义,它不保存状态,也不提供互斥保护。所有对共享数据的读写、以及 wait() / notify_one() 的调用,都必须在同一个 std::mutex 的保护下进行。

常见错误是只用 mutex 保护数据修改,却在 unlock 后才调用 notify_one() —— 这会导致唤醒丢失:消费者刚 wait 完、还没来得及重新加锁,生产者就 notify 了,信号被丢弃。

  • 正确做法:在持有 mutex 时修改完共享状态(如 push 到队列),**立刻**调用 notify_one()notify_all(),再 unlock
  • wait() 内部会自动 unlock mutex,并在被唤醒后重新 lock;但唤醒后仍需检查条件是否真正满足(用 while 循环,不是 if)
  • 不要依赖“通知次数”:notify_one() 只唤醒一个等待线程,但无法保证是哪个;多个消费者竞争时,要用循环重检条件

wait() 必须配合谓词(predicate)使用

wait() 的裸调用(无 lambda)极易出错,因为 spurious wakeup(虚假唤醒)在 POSIX 和 C++ 标准中都是允许的。哪怕没人 notify,线程也可能被唤醒。

所以不能写 cv.wait(lock) 然后直接消费,而必须用 while 循环检查条件是否成立:

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

while (queue.empty()) {
    cv.wait(lock);
}

更推荐用带谓词的重载,语义清晰且自动处理循环:

智川X-Agent
智川X-Agent

中科闻歌推出的一站式AI智能体开发平台

下载
cv.wait(lock, [&] { return !queue.empty(); });
  • 谓词返回 false → 继续 wait 并自动 unlock/relock
  • 谓词返回 true → 退出 wait,lock 保持已持有状态
  • 如果用 if 而非 while,一次虚假唤醒就可能导致访问空队列,触发未定义行为

notify_one() vs notify_all() 的实际影响

在生产者-消费者模型中,多数情况用 notify_one() 就够了。它开销小、可预测性高,尤其当只有一个消费者在等时,避免唤醒所有线程抢锁。

但要注意边界场景:

  • 如果消费者逻辑里有多个 condition_variable(比如“有数据”和“缓冲区有空位”共用同一队列),或存在优先级调度,notify_one() 可能唤醒错的等待者
  • 当所有消费者都在等,而生产者一次 push 多个元素,用 notify_one() 会导致其余消费者继续沉睡,吞吐下降
  • notify_all() 不会死锁,但会引发“惊群”,所有等待线程争抢 mutex,其中仅一个能成功进入临界区,其余再次阻塞 —— 在高并发下可能拖慢整体响应

简单模型建议:单生产者 + 单消费者 → notify_one();多消费者且生产者常批量写入 → 考虑 notify_all(),但务必确保谓词检查足够轻量。

别忘了设置停止标志并通知所有等待线程

程序退出前,若还有线程在 wait(),它们会永远卡住。常见做法是引入 std::atomic<bool> done</bool> 作为全局退出信号,并在析构或 shutdown 时设为 true,再调用 notify_all()

消费者端需同时检查两个条件:

while (!done && queue.empty()) {
    cv.wait(lock);
}
if (done && queue.empty()) {
    break; // 退出循环
}
  • 只靠 notify_all() 不够:唤醒后仍要检查 done,否则可能取到旧数据后继续等下一次
  • 不能只检查 done:万一先设了 done = true,但消费者还没开始 wait,就会跳过 wait 直接 break,漏掉队列中残留数据
  • 生产者在 push 最后一批数据后,也应调用 notify_all(),确保消费者有机会处理完所有内容

没处理好退出逻辑,是调试时最难复现的 hang 问题之一 —— 它往往只在程序关闭瞬间出现,且不报错。

热门AI工具

更多
DeepSeek
DeepSeek

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

豆包大模型
豆包大模型

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

通义千问
通义千问

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

腾讯元宝
腾讯元宝

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

文心一言
文心一言

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

讯飞写作
讯飞写作

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

即梦AI
即梦AI

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

ChatGPT
ChatGPT

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

相关专题

更多
if什么意思
if什么意思

if的意思是“如果”的条件。它是一个用于引导条件语句的关键词,用于根据特定条件的真假情况来执行不同的代码块。本专题提供if什么意思的相关文章,供大家免费阅读。

846

2023.08.22

while的用法
while的用法

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

106

2023.09.25

java中break的作用
java中break的作用

本专题整合了java中break的用法教程,阅读专题下面的文章了解更多详细内容。

120

2025.10.15

java break和continue
java break和continue

本专题整合了java break和continue的区别相关内容,阅读专题下面的文章了解更多详细内容。

261

2025.10.24

lambda表达式
lambda表达式

Lambda表达式是一种匿名函数的简洁表示方式,它可以在需要函数作为参数的地方使用,并提供了一种更简洁、更灵活的编码方式,其语法为“lambda 参数列表: 表达式”,参数列表是函数的参数,可以包含一个或多个参数,用逗号分隔,表达式是函数的执行体,用于定义函数的具体操作。本专题为大家提供lambda表达式相关的文章、下载、课程内容,供大家免费下载体验。

215

2023.09.15

python lambda函数
python lambda函数

本专题整合了python lambda函数用法详解,阅读专题下面的文章了解更多详细内容。

192

2025.11.08

Python lambda详解
Python lambda详解

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

61

2026.01.05

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

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

765

2023.08.10

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

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

76

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号