讲师中心 微信公众号
AI工具推荐 视频效率加速

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

夏萱大大_4049

夏萱大大_4049

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

|

345人浏览过

|

来源于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);
}

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

C++14
C++14

C++14 对 C++11 的修正与增强版本,适合旧系统维护和较老工具链兼容。

下载
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 问题之一 —— 它往往只在程序关闭瞬间出现,且不报错。

相关文章

c++速学教程(入门到精通)
c++速学教程(入门到精通)

c++怎么学习?c++怎么入门?c++在哪学?c++怎么学才快?不用担心,这里为大家提供了c++速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热门AI工具

更多
二狗PPT
二狗PPT Hot

一款AI演示文稿工具,主要用于专为中式职场打造的AI PPT生成工具,适合需要提升相关任务效率的用户。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

讯飞智作

讯飞智作是一款AI视频创作工具,AI文本配音工具,数字人课程、营销视频制作。

墨刀AI
墨刀AI Hot

一款AI图像与设计工具,主要用于产品经理的专属智能体,适合需要提升相关任务效率的用户。

讯飞绘文

讯飞绘文是一款由科大讯飞推出的一站式 AIGC 内容运营平台。

火山引擎

火山引擎是一款面向企业的云计算与AI服务平台。

立刻MV
立刻MV Hot

立刻MV是一款AI文本写作工具,AI 音乐视频(MV)创作工具。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

相关专题

更多
while的用法
while的用法

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

354

2023.09.25

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

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

2680

2025.10.15

java break和continue
java break和continue

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

767

2025.10.24

lambda表达式
lambda表达式

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

991

2023.09.15

python lambda函数
python lambda函数

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

345

2025.11.08

Python lambda详解
Python lambda详解

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

514

2026.01.05

C++ Lambda 表达式与函数式编程
C++ Lambda 表达式与函数式编程

深入讲解 C++ Lambda 表达式与函数式编程范式,涵盖 Lambda 基础语法与返回值推导、值捕获与引用捕获的区别与陷阱、初始化捕获(C++14 广义捕获)、泛型 Lambda(auto 参数)、mutable 关键字修改捕获变量、std::function 类型擦除与函数包装、std::bind 参数绑定(及其被 Lambda 替代的趋势)、Lambda 在 STL 算法(sort/transform/for_each/remo

669

2026.05.06

Java 函数式接口与 Lambda 进阶技巧
Java 函数式接口与 Lambda 进阶技巧

在 Java Stream 基础之上进一步深入函数式编程,涵盖 @FunctionalInterface 注解与自定义函数式接口设计、四种方法引用(静态/实例/对象/构造器)的使用场景、Lambda 中的 effectively final 变量捕获规则、函数组合(andThen/compose)与柯里化技巧、Comparator 链式比较器构建、CompletableFuture 异步函数式编排、Reactor / RxJava 响应

408

2026.05.08

OpenJDK JVM参数怎么调优
OpenJDK JVM参数怎么调优

Java应用运行缓慢,如何调整JVM参数?本专题介绍OpenJDK JVM性能调优的基本流程,涵盖性能指标确认、运行数据采集、内存配置和垃圾回收分析,帮助你先定位瓶颈,再通过对照测试验证效果,避免直接套用参数而影响应用稳定性。

0

2026.10.16

热门下载

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

精品课程

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

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn