0

0

C++怎么实现生产者消费者模型_C++多线程同步应用【实战】

裘德小鎮的故事

裘德小鎮的故事

发布时间:2026-03-12 16:05:32

|

451人浏览过

|

来源于php中文网

原创

用std::mutex和std::condition_variable实现生产者消费者队列时,必须用带谓词的wait循环检测条件、notify前更新状态、避免虚假唤醒;多消费者场景下notify_one更高效,std::queue+锁比无锁队列更稳妥可靠。

c++怎么实现生产者消费者模型_c++多线程同步应用【实战】

std::mutex + std::condition_variable 实现基础版生产者消费者

标准库里没有现成的“生产者消费者队列”,得自己搭。核心是保护共享队列、阻塞空消费和满生产,std::mutexstd::condition_variable 是唯二必须的同步原语。

常见错误是只锁不等,比如消费者发现队列空就直接 return,结果漏掉后续通知;或者生产者没检查容量就 push,导致死锁或数据丢失。

  • 消费者循环里必须用 cv.wait(lock, [&]{ return !queue.empty(); }),不能写成 if (queue.empty()) cv.wait(...)
  • 每次 notify_one() 前要确保状态已更新(比如 push 或 pop 完成),否则唤醒后仍可能失败
  • std::condition_variable::wait 有虚假唤醒风险,必须配合谓词 lambda 使用,不能裸调用

示例片段:

std::queue<int> queue;
std::mutex mtx;
std::condition_variable cv_produce, cv_consume;

// 生产者
void produce(int val) {
    std::unique_lock<std::mutex> lock(mtx);
    cv_produce.wait(lock, [&]{ return queue.size() < CAPACITY; });
    queue.push(val);
    cv_consume.notify_one(); // 通知消费者有新数据
}

// 消费者
int consume() {
    std::unique_lock<std::mutex> lock(mtx);
    cv_consume.wait(lock, [&]{ return !queue.empty(); });
    int val = queue.front();
    queue.pop();
    cv_produce.notify_one(); // 通知生产者有空位
    return val;
}

为什么不用 std::semaphore(C++20)?

C++20 引入了 std::counting_semaphore,理论上更贴近信号量语义,但实际用起来限制多、兼容性差。

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

主要问题不是功能不够,而是落地难:MSVC 19.3x 才开始支持,Clang 12+ 且需 -std=c++20 -lpthread,GCC 12+ 默认不启用。很多项目还卡在 C++17。

飞书多维表格
飞书多维表格

表格形态的AI工作流搭建工具,支持批量化的AI创作与分析任务,接入DeepSeek R1满血版

下载
  • 即使编译通过,std::counting_semaphore 构造时传负数会抛 std::system_error,而传统 condvar 方案出错更早、更容易定位
  • 它不提供“等待满足某条件”的能力,比如“队列非空且元素为偶数”,还得套一层 mutex + lambda
  • 调试时无法像 std::condition_variable 那样观察 wait 的谓词逻辑,堆栈里只看到 sem_wait

多个生产者 / 多个消费者时,notify_one() 还够用吗?

够,但要看场景。单个消费者时用 notify_one() 是最优解;多个消费者共用一个队列时,也推荐 notify_one(),除非你明确需要“广播式唤醒”。

误用 notify_all() 是高频性能坑:100 个消费者线程同时被唤醒,只有 1 个能抢到锁并消费,其余 99 个立刻再次进入 wait,白白消耗 CPU 和上下文切换。

  • 如果消费者处理耗时长,且希望“尽可能让空闲消费者立即接手”,才考虑 notify_one() 配合 std::this_thread::yield() 让出时间片
  • 若存在优先级区分(如高优任务插队),需额外加字段标记,不能只靠 notify 策略解决
  • 所有 notify 调用必须在持有 mutex 的前提下完成,否则行为未定义

队列类型选 std::queue 还是 boost::lockfree::queue

绝大多数情况坚持用 std::queue + 锁。无锁队列不是银弹,反而容易引入更隐蔽的问题。

boost::lockfree::queue 要求元素可复制/可移动,且默认固定大小;一旦 push 失败(队列满),它直接返回 false,不会阻塞——这和生产者消费者的原始语义冲突,你得自己补重试或降级逻辑。

  • 内存模型复杂:它依赖 std::atomic 底层操作,在 ARM 或旧 x86 上可能因内存序问题导致读到脏数据
  • 调试困难:gdb 无法自然打印其内部状态,size() 返回值也不一定实时准确
  • 仅当单生产者单消费者(SPSC)且吞吐压测证明瓶颈真在锁上时,才值得评估替换

真正该优化的地方通常是队列操作本身:避免在临界区做深拷贝、预分配空间、用 std::move 转移大对象。

真实项目里最难调的从来不是“怎么写通”,而是“什么时候该唤醒”“谁负责清理资源”“异常路径下锁是否一定释放”。这些细节藏在业务逻辑缝里,没法靠模板代码覆盖。

热门AI工具

更多
DeepSeek
DeepSeek

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

豆包大模型
豆包大模型

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

WorkBuddy
WorkBuddy

腾讯云推出的AI原生桌面智能体工作台

腾讯元宝
腾讯元宝

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

文心一言
文心一言

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

讯飞写作
讯飞写作

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

即梦AI
即梦AI

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

ChatGPT
ChatGPT

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

相关专题

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

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

846

2023.08.22

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

堆和栈的区别
堆和栈的区别

堆和栈的区别:1、内存分配方式不同;2、大小不同;3、数据访问方式不同;4、数据的生命周期。本专题为大家提供堆和栈的区别的相关的文章、下载、课程内容,供大家免费下载体验。

443

2023.07.18

堆和栈区别
堆和栈区别

堆(Heap)和栈(Stack)是计算机中两种常见的内存分配机制。它们在内存管理的方式、分配方式以及使用场景上有很大的区别。本文将详细介绍堆和栈的特点、区别以及各自的使用场景。php中文网给大家带来了相关的教程以及文章欢迎大家前来学习阅读。

605

2023.08.10

堆和栈的区别
堆和栈的区别

堆和栈的区别:1、内存分配方式不同;2、大小不同;3、数据访问方式不同;4、数据的生命周期。本专题为大家提供堆和栈的区别的相关的文章、下载、课程内容,供大家免费下载体验。

443

2023.07.18

堆和栈区别
堆和栈区别

堆(Heap)和栈(Stack)是计算机中两种常见的内存分配机制。它们在内存管理的方式、分配方式以及使用场景上有很大的区别。本文将详细介绍堆和栈的特点、区别以及各自的使用场景。php中文网给大家带来了相关的教程以及文章欢迎大家前来学习阅读。

605

2023.08.10

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

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

76

2026.03.11

热门下载

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

精品课程

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

共94课时 | 11.2万人学习

C 教程
C 教程

共75课时 | 5.4万人学习

C++教程
C++教程

共115课时 | 21.6万人学习

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

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