讲师中心 微信公众号

工具推荐

视频效率加速
Laper
Laper

剧本策划到成片协作

立刻MV
立刻MV

低成本歌曲 MV、视频生成

Seko
Seko

AI短剧一键生成成片

剧云
剧云

中文短剧剧本制作平台

C++如何实现生产者消费者阻塞队列_C++结合条件变量实现同步【案例】

夜杰同学_3407

夜杰同学_3407

发布时间:2026-02-04 16:02:01

|

763人浏览过

|

来源于php中文网

原创

直接用std::queue加互斥锁会导致忙等待和无法感知新元素,需配合std::condition_variable实现线程挂起与唤醒;wait必须用std::unique_lock,推荐带谓词的wait避免虚假唤醒;有界队列需两个条件变量分别管理空与满状态。

c++如何实现生产者消费者阻塞队列_c++结合条件变量实现同步【案例】

为什么直接用 std::queue 加互斥锁会出问题

因为消费者线程在队列为空时,如果只是加锁后发现 empty() 为真,就立刻解锁并循环重试,这会引发忙等待(busy-waiting),浪费 CPU;更严重的是,它无法感知“何时有新元素到来”,导致要么卡死、要么漏通知。必须让线程在无数据时主动挂起,等生产者插入后再唤醒——这正是 std::condition_variable 的作用。

std::condition_variable::wait() 必须和 std::unique_lock<:mutex></:mutex> 配合使用

wait() 不是独立工作的:它会在进入等待前自动释放锁,并在线程被唤醒且重新获得锁后才返回。如果不传 std::unique_lock,编译直接报错;若传 std::lock_guard,则因类型不匹配而失败。常见错误写法:cv.wait(lock) 中的 lock 是 std::lock_guard —— 这会导致未定义行为。

  • 消费者等待逻辑应写成:cv.wait(lock, [&] { return !q.empty(); });(带谓词的 wait,避免虚假唤醒)
  • 生产者通知只需调用 cv.notify_one()(单个消费者唤醒)或 cv.notify_all()(全部唤醒,适合多消费者竞争场景)
  • 注意:notify 可以在锁内或锁外调用,但放在锁内更易保证唤醒时机不被调度器打乱

阻塞队列的 push/pop 接口要区分「阻塞」和「超时」语义

实际工程中,你往往需要两种行为:一种是无条件阻塞直到成功(如核心工作流),另一种是带超时的尝试操作(如响应式任务或资源受限场景)。标准库没提供现成封装,得自己实现:

  • push(T&& item):加锁 → 入队 → cv.notify_one(),无返回值
  • pop(T& item):加锁 → cv.wait(...) 等非空 → 出队,成功返回 true
  • try_pop_for(T& item, std::chrono::milliseconds timeout):用 cv.wait_for(),返回 std::cv_status::timeout 或 no_timeout,再判断队列是否真有数据

漏掉超时判断或忽略 wait_for() 返回值,会导致看似“超时了”其实仍卡在 pop 上。

C++14
C++14

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

下载

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

多个条件变量容易混淆:空 vs 满,该用几个?

如果你的队列有容量上限(即有界阻塞队列),就需要两个条件变量:not_empty_cv 和 not_full_cv,分别控制消费者和生产者的等待。只用一个 cv 会导致:当队列满时,生产者 wait 后被 notify_one() 唤醒,但唤醒源可能是消费者 pop 后触发的同一通知——它本意是告诉“有空间了”,却可能误唤醒另一个生产者,造成竞争或逻辑错乱。

  • 有界队列中,push() 要先等 not_full_cv,再入队,再 notify not_empty_cv
  • pop() 要先等 not_empty_cv,再出队,再 notify not_full_cv
  • 两个 cv 对应两把“门禁”,混用或省略其中一个,边界控制就失效了

很多人一开始用无界队列测试没问题,一加上容量限制就死锁,问题几乎都出在这里。

热门AI工具

更多
Flowith
Flowith Hot

Flowith是一款基于画布和智能体工作流的 AI 协作工作空间。

UP简历
UP简历 Hot

一款AI办公效率工具,主要用于基于AI技术的免费在线简历制作工具,适合需要提升相关任务效率的用户。

码上飞
码上飞 Hot

一款基于自然语言的AI应用开发平台,可根据用户描述自动生成应用程序,帮助个人和团队快速完成应用原型与开发。

豆包大模型

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

DeepSeek

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

小橡皮AI

一款AI工具,主要用于小橡皮一键去AI味,将机器味重的内容改得更有活人感,防止因为 AI 内容被平台打上 AI 标签,以及限流,适合需要提升相关任务效率的用户。

PixTV
PixTV Hot

PixTV是一款面向AIGC内容创作的AI视频生成工具。

WorkBuddy

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

Loomy
Loomy Hot

一款AI工具,主要用于科大讯飞发布的桌面级 AI 助理,比 OpenClaw 更易用、更安全!,适合需要提升相关任务效率的用户。

相关专题

更多
硬盘接口类型介绍
硬盘接口类型介绍

硬盘接口类型有IDE、SATA、SCSI、Fibre Channel、USB、eSATA、mSATA、PCIe等等。详细介绍:1、IDE接口是一种并行接口,主要用于连接硬盘和光驱等设备,它主要有两种类型:ATA和ATAPI,IDE接口已经逐渐被SATA接口;2、SATA接口是一种串行接口,相较于IDE接口,它具有更高的传输速度、更低的功耗和更小的体积;3、SCSI接口等等。

3248

2023.10.19

PHP接口编写教程
PHP接口编写教程

本专题整合了PHP接口编写教程,阅读专题下面的文章了解更多详细内容。

5469

2025.10.17

php8.4实现接口限流的教程
php8.4实现接口限流的教程

PHP8.4本身不内置限流功能,需借助Redis(令牌桶)或Swoole(漏桶)实现;文件锁因I/O瓶颈、无跨机共享、秒级精度等缺陷不适用高并发场景。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

3909

2025.12.29

java接口相关教程
java接口相关教程

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

506

2026.01.19

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

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

4858

2023.08.10

Go-Zero API开发使用教程
Go-Zero API开发使用教程

本专题聚焦Go-Zero的API开发,拆解.api描述文件的语法结构、路由与分组定义、参数绑定与校验规则,说明统一响应体、JWT鉴权、跨域与接口文档生成的落地方式,并给出网关聚合与接口测试的实践建议。

20

2026.11.12

Go-Zero安装与goctl环境配置教程
Go-Zero安装与goctl环境配置教程

本专题围绕Go-Zero的安装与工具链配置展开,讲清Go版本要求、goctl安装方式、代理镜像、protoc依赖与环境变量设置,说明多版本共存、升级回退与CI流水线安装的做法,并整理安装阶段的常见报错与验证步骤。

20

2026.11.12

Go-Zero零基础入门教程
Go-Zero零基础入门教程

本专题整理Go-Zero的入门知识,从框架定位、环境准备到跑通第一个API服务,讲清目录分层、配置加载、日志与中间件的基本用法,并对比Gin、Kratos的差异,帮助Go开发者建立整体认知,判断它是否适合当前项目。

20

2026.11.12

Postman身份认证怎么配置
Postman身份认证怎么配置

本专题从实际API接口调试场景出发,讲解Postman身份认证的完整配置流程,包括常见认证协议介绍、授权参数设置、访问令牌填写、OAuth 2.0授权及认证失败排查,帮助用户正确完成接口授权与访问验证。

120

2026.11.06

热门下载

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

精品课程

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

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