0

0

c++如何实现生产者消费者模式_c++条件变量condition_variable【核心】

尼克

尼克

发布时间:2026-02-13 15:15:14

|

335人浏览过

|

来源于php中文网

原创

std::mutex无法解决生产者消费者同步问题,因其仅提供互斥访问,无法实现条件等待与精准唤醒;必须配合std::condition_variable和std::unique_lock,用while循环检查条件、在持锁时notify,且区分空满条件变量。

c++如何实现生产者消费者模式_c++条件变量condition_variable【核心】

为什么直接用 std::mutex 无法解决生产者消费者同步问题

因为互斥锁只能保证「同一时间只有一个线程访问共享资源」,但无法让线程在条件不满足时主动等待、并在条件达成后被精准唤醒。比如消费者发现队列为空,它不能死循环 while (queue.empty()) 占着 CPU,也不能随便 sleep 一段固定时间——这既低效又不可靠。

真正需要的是:「挂起当前线程,释放锁,等别人通知我条件变了再重新抢锁继续执行」。这就是 std::condition_variable 的核心价值。

注意:std::condition_variable 必须和 std::unique_lock<:mutex></:mutex> 配合使用,不能配 std::lock_guard,也不能单独存在。

如何正确使用 wait() 避免虚假唤醒和逻辑错位

wait() 可能因系统信号等原因被唤醒(虚假唤醒),所以必须用 while 循环检查条件,而不是 if。同时,wait() 内部会自动释放锁,并在唤醒后重新加锁——这是关键机制。

易企秀
易企秀

易企秀,一体化创意设计营销平台。超100万模板1键套用3分钟制作,随时随地完成创意设计营销。

下载

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

  • 错误写法:if (queue.empty()) cv.wait(lock); → 可能跳过真实唤醒或误判
  • 正确写法:while (queue.empty()) cv.wait(lock); → 每次唤醒都重新校验
  • 别忘了:cv.notify_one()cv.notify_all() 必须在修改完共享状态(如 push/pop)且仍持有锁时调用,否则消费者可能在 notify 前就 wait 进去了,导致丢失信号

生产者和消费者线程中 notify 的选择:one 还是 all

多数情况下用 cv.notify_one() 就够了——一个新元素入队,只需唤醒一个等待的消费者;一个元素出队,只需唤醒一个等待的生产者(如果用了有界队列)。用 notify_all() 会导致多个线程争抢锁和资源,徒增开销。

但要注意边界场景:

  • 如果消费者处理非常慢,而生产者频繁 notify_one,可能导致部分消费者长期饥饿
  • 若实现「广播式」语义(如关闭信号、清空指令),才需 notify_all()
  • 永远不要在无锁状态下调用 notify —— 它不保证线程安全,只是发信号,但前提是你已经确保状态已更新完毕

完整可运行的关键骨架(省略头文件和命名空间)

std::queue<int> q;
std::mutex mtx;
std::condition_variable cv_producer, cv_consumer;
const int MAX_SIZE = 10;

// 生产者
void producer() {
    for (int i = 0; i < 20; ++i) {
        std::unique_lock<std::mutex> lock(mtx);
        while (q.size() == MAX_SIZE) {
            cv_producer.wait(lock); // 等待队列有空位
        }
        q.push(i);
        cv_consumer.notify_one(); // 通知至少一个消费者
    }
}

// 消费者
void consumer() {
    while (true) {
        std::unique_lock<std::mutex> lock(mtx);
        while (q.empty()) {
            cv_consumer.wait(lock); // 等待队列非空
        }
        int val = q.front();
        q.pop();
        lock.unlock(); // 提前释放锁,避免阻塞生产者
        process(val);  // 实际处理,不占共享锁
        cv_producer.notify_one(); // 通知生产者队列有空位
    }
}

这里有两个易忽略点:一是消费者在 process() 前主动 unlock(),避免处理耗时操作时霸占锁;二是两个 condition_variable 分开使用(cv_producercv_consumer),比共用一个更清晰、不易互相干扰——尤其在有界队列中,空和满是两个独立条件。

相关文章

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

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

下载

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

热门AI工具

更多
DeepSeek
DeepSeek

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

豆包大模型
豆包大模型

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

通义千问
通义千问

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

腾讯元宝
腾讯元宝

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

文心一言
文心一言

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

讯飞写作
讯飞写作

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

即梦AI
即梦AI

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

ChatGPT
ChatGPT

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

相关专题

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

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

807

2023.08.22

while的用法
while的用法

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

102

2023.09.25

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

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

673

2023.08.10

pixiv网页版官网登录与阅读指南_pixiv官网直达入口与在线访问方法
pixiv网页版官网登录与阅读指南_pixiv官网直达入口与在线访问方法

本专题系统整理pixiv网页版官网入口及登录访问方式,涵盖官网登录页面直达路径、在线阅读入口及快速进入方法说明,帮助用户高效找到pixiv官方网站,实现便捷、安全的网页端浏览与账号登录体验。

12

2026.02.13

微博网页版主页入口与登录指南_官方网页端快速访问方法
微博网页版主页入口与登录指南_官方网页端快速访问方法

本专题系统整理微博网页版官方入口及网页端登录方式,涵盖首页直达地址、账号登录流程与常见访问问题说明,帮助用户快速找到微博官网主页,实现便捷、安全的网页端登录与内容浏览体验。

7

2026.02.13

Flutter跨平台开发与状态管理实战
Flutter跨平台开发与状态管理实战

本专题围绕Flutter框架展开,系统讲解跨平台UI构建原理与状态管理方案。内容涵盖Widget生命周期、路由管理、Provider与Bloc状态管理模式、网络请求封装及性能优化技巧。通过实战项目演示,帮助开发者构建流畅、可维护的跨平台移动应用。

6

2026.02.13

TypeScript工程化开发与Vite构建优化实践
TypeScript工程化开发与Vite构建优化实践

本专题面向前端开发者,深入讲解 TypeScript 类型系统与大型项目结构设计方法,并结合 Vite 构建工具优化前端工程化流程。内容包括模块化设计、类型声明管理、代码分割、热更新原理以及构建性能调优。通过完整项目示例,帮助开发者提升代码可维护性与开发效率。

6

2026.02.13

Redis高可用架构与分布式缓存实战
Redis高可用架构与分布式缓存实战

本专题围绕 Redis 在高并发系统中的应用展开,系统讲解主从复制、哨兵机制、Cluster 集群模式及数据分片原理。内容涵盖缓存穿透与雪崩解决方案、分布式锁实现、热点数据优化及持久化策略。通过真实业务场景演示,帮助开发者构建高可用、可扩展的分布式缓存系统。

1

2026.02.13

c语言 数据类型
c语言 数据类型

本专题整合了c语言数据类型相关内容,阅读专题下面的文章了解更多详细内容。

25

2026.02.12

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
C# 教程
C# 教程

共94课时 | 9.3万人学习

C 教程
C 教程

共75课时 | 4.7万人学习

C++教程
C++教程

共115课时 | 17.4万人学习

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

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