C++实现生产者消费者之阻塞队列 _ 互斥锁与条件变量封装【源码】

老伟大大_4085

老伟大大_4085

2026-04-12

792人浏览

原创

直接用 std::queue 加 std::mutex 会卡死,因缺乏等待通知机制:生产者队列满、消费者队列空时需挂起线程而非忙等,必须配合 std::condition_variable 实现条件等待与唤醒。

c++实现生产者消费者之阻塞队列 _ 互斥锁与条件变量封装【源码】

为什么直接用 std::queue 加 std::mutex 会卡死?

因为缺少「等待通知」机制:生产者发现队列满时,不能忙等;消费者发现队列空时,也不能轮询。必须让线程挂起,等条件满足再唤醒——这正是 std::condition_variable 的作用。只加锁不唤醒,线程会在 while (queue.empty()) { /* do nothing */ } 里耗尽 CPU。

常见错误现象:std::system_error: Operation not permitted(没和互斥量配合使用)、程序看似运行但无输出(消费者永远等不到通知)、偶发崩溃(notify_one() 调用时无人在 wait)。

实操建议:

  • wait() 必须传入已上锁的 std::unique_lock<:mutex></:mutex>,且内部会自动释放锁并挂起;被唤醒后重新加锁才返回
  • 用 wait(lock, predicate) 形式(带谓词的重载),避免虚假唤醒——不要写裸 wait() 后再 if 判断
  • 通知方(notify_one() 或 notify_all())无需持有锁,但习惯上在修改共享状态后、释放锁前调用更安全

BlockingQueue 封装时,push() 和 pop() 的阻塞逻辑怎么写?

核心是把「检查条件 → 等待 → 执行操作」三步收进一个原子流程。比如 pop() 必须确保:只有非空时才取值,且取值过程不被其他线程打断。

示例关键片段:

template <typename t>
T BlockingQueue<t>::pop() {
    std::unique_lock<:mutex> lock(mtx_);
    cond_not_empty_.wait(lock, [this] { return !queue_.empty(); });
    T item = std::move(queue_.front());
    queue_.pop();
    cond_not_full_.notify_one(); // 可能腾出空间,通知生产者
    return item;
}</:mutex></t></typename>

注意点:

C++14
C++14

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

下载
  • push() 里用 cond_not_full_.wait() 检查容量,pop() 用 cond_not_empty_.wait() 检查非空,两个条件变量分工明确
  • 如果队列有大小限制(如 ring buffer),push() 中的谓词应为 queue_.size() ,而非 <code>!queue_.full()(除非你实现了 full())
  • 返回值用 std::move() 避免冗余拷贝;若类型不可移动,需按需处理(例如提供 const 引用版本)

多生产者多消费者场景下,notify_one() 和 notify_all() 怎么选?

多数情况下用 notify_one() 就够了——它唤醒一个等待线程,开销小、无惊群效应。只有当多个等待线程依赖同一状态变更(比如广播式关闭信号),才需要 notify_all()。

典型误用:

  • 在 push() 末尾调用 notify_all() 唤醒所有消费者:浪费,只有一个消费者能抢到元素,其余又被挡在 wait() 里
  • 用 notify_one() 但没配对好条件变量:比如 push() 只 notify cond_not_empty_,却期望消费者响应 cond_not_full_(根本不会触发)

性能影响:频繁 notify_all() 在百级线程规模下会导致明显调度抖动;而 notify_one() 基本是 O(1)。

析构函数里怎么安全停止所有等待线程?

不能直接销毁条件变量或互斥量——可能有线程正卡在 wait() 中。必须先中断等待逻辑,常用做法是引入「关闭标志 + 通知」组合。

实操建议:

  • 加一个 std::atomic_bool closed_{false} 成员,在析构前设为 true,并在所有 wait() 谓词中加入 !closed_ && ...
  • 析构函数中先 closed_ = true,再调用 cond_not_empty_.notify_all() 和 cond_not_full_.notify_all(),确保所有 wait 返回
  • 然后 join 所有工作线程(如果你管理线程生命周期),最后才让成员变量析构

容易被忽略的是:即使设置了 closed_,仍要保证 pop() 在关闭后不崩溃——可约定关闭后 pop() 抛异常或返回 std::nullopt(需模板支持 std::optional)。

C++免费学习笔记(深入):立即使用
在学习笔记中,你将探索 C++ 的入门与实战技巧!

相关文章

PHP速学视频免费教程(入门到精通)
PHP速学视频免费教程(入门到精通)

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

下载

相关标签:

c++

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

相关专题

更多
while的用法
while的用法

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

2023.09.25

354

5

c语言const用法
c语言const用法

const是关键字,可以用于声明常量、函数参数中的const修饰符、const修饰函数返回值、const修饰指针。详细介绍:1、声明常量,const关键字可用于声明常量,常量的值在程序运行期间不可修改,常量可以是基本数据类型,如整数、浮点数、字符等,也可是自定义的数据类型;2、函数参数中的const修饰符,const关键字可用于函数的参数中,表示该参数在函数内部不可修改等等。

2023.09.20

2258

7

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

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

2023.08.10

4318

6

Gradle插件开发入门教程
Gradle插件开发入门教程

本专题介绍Gradle插件开发的基本流程,涵盖插件类编写、自定义任务注册、扩展参数设计和插件应用方法,帮助你理解插件如何组织构建逻辑,减少多个项目之间的重复配置。

2026.10.22

20

11

Gradle Wrapper配置教程
Gradle Wrapper配置教程

本专题介绍Gradle Wrapper的基本作用,涵盖文件组成、生成方法、版本配置和任务调用,帮助你理解项目如何使用指定的Gradle版本,减少不同开发环境带来的构建差异。

2026.10.22

0

10

Golangci-lint检查器使用教程
Golangci-lint检查器使用教程

本专题整理Golangci-lint常用Linters的用途与配置方法,覆盖错误处理、无效代码、安全、复杂度、命名和依赖检查,帮助项目合理选规则。

2026.10.22

20

15

Gradle怎么构建Java项目
Gradle怎么构建Java项目

本专题介绍Gradle Java项目构建方法,涵盖Java插件配置、依赖声明、源码编译、测试执行和打包检查,帮助你理解各阶段的任务关系,逐步完成项目构建。

2026.10.22

0

10

PHP时间戳漏洞修复教程
PHP时间戳漏洞修复教程

本专题汇总PHP常见时间戳漏洞,包括2038年溢出、时区漂移、时间戳伪造、重放攻击、时间盲注与日志审计失效等,并给出升级64位环境、使用 DateTimeImmutable、统一UTC、严格超时校验、预处理绑定、hash_equals 比对等修复方案,帮助开发者快速排查和加固时间相关代码。

2026.10.22

20

25

Golangci-lint配置文件与规则设置
Golangci-lint配置文件与规则设置

本专题聚焦Golangci-lint YAML配置文件,讲清运行参数、规则启停、目录排除、问题过滤及严重级别设置,便于团队统一检查标准。

2026.10.22

0

15

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
C++ Core Guidelines
C++ Core Guidelines

共0课时 | 0人学习

C++ Reference
C++ Reference

共0课时 | 0人学习

C++ 官方标准说明
C++ 官方标准说明

共0课时 | 0人学习