0

0

c++如何实现一个线程安全的队列_c++锁与条件变量的应用【多线程】

冰火之心

冰火之心

发布时间:2025-12-17 15:14:02

|

459人浏览过

|

来源于php中文网

原创

线程安全队列需用互斥锁保障操作原子性,条件变量实现阻塞等待,移动语义减少拷贝,可选超时与关闭机制提升鲁棒性。

c++如何实现一个线程安全的队列_c++锁与条件变量的应用【多线程】

用互斥锁保护队列操作

线程安全队列的核心是确保多个线程对共享队列的访问不会导致数据竞争。最直接的方式是用 std::mutex 串行化所有入队(push)和出队(pop)操作。每次修改队列前加锁,操作完立即解锁,避免长时间持锁影响并发性能。

  • 声明一个 mutable std::mutex mtx 成员(mutable 允许 const 成员函数中加锁)
  • push() 中 lock() → 插入 → unlock()
  • pop() 中同样加锁、检查非空、取值、erase 或 pop_front,再解锁
  • 注意:pop 若队列为空,应返回失败标识(如 false)或抛异常,不能假设一定有元素

用条件变量实现阻塞式 pop

纯互斥锁只能保证安全,但无法让消费者线程在队列为空时“等一等”。这时需要 std::condition_variable 配合使用:消费者等待条件(!empty),生产者在 push 后 notify_one() 唤醒一个等待者。

  • 搭配 std::unique_lock<:mutex> 使用(条件变量 wait 必须用 unique_lock)
  • pop_wait() 中先加锁,然后 while(empty()) cv.wait(lock) —— 必须用 while 而非 if,防止虚假唤醒
  • push() 中插入后调用 cv.notify_one()(或 notify_all,按需选择)
  • 注意:notify 可以在锁内或锁外执行,但放在锁内更易推理;wait 会自动释放锁并挂起,被唤醒后重新获取锁再继续

避免拷贝、支持移动语义

高效队列应尽量减少对象复制。使用 std::queue> 作为底层容器,它默认支持 move 语义;对外接口用右值引用重载 push:

  • void push(T&& val) → 直接 emplace_back 移动入队
  • void push(const T& val) → 拷贝入队(保留兼容性)
  • pop_wait() 返回值建议用 std::optional(C++17)或自定义 Result 类包装,避免传引用出作用域
  • 若用指针或智能指针(如 std::shared_ptr),可进一步解耦生命周期,适合大对象或异构任务

可选增强:带超时的 pop 和关闭机制

真实场景常需限时等待或优雅停止。可用 cv.wait_for() 实现超时 pop;添加 shutdown_flag 布尔成员(配合 atomic)支持主动终止等待:

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

  • shutdown() 设置 flag 并 notify_all()
  • pop_wait() 的 while 循环改为 while(empty() && !shutdown_),并在 wait 后检查 shutdown_
  • wait_for 第二个参数传 std::chrono::milliseconds(500),超时返回 std::nullopt
  • 注意:shutdown_ 应为 std::atomic,避免数据竞争且无需额外锁
基本上就这些。锁保安全,条件变量管等待,移动提效率,超时与关闭增鲁棒性——组合起来就是一个工业级可用的线程安全队列。

相关专题

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

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

738

2023.08.22

while的用法
while的用法

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

85

2023.09.25

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

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

523

2023.09.20

javascriptvoid(o)怎么解决
javascriptvoid(o)怎么解决

javascriptvoid(o)的解决办法:1、检查语法错误;2、确保正确的执行环境;3、检查其他代码的冲突;4、使用事件委托;5、使用其他绑定方式;6、检查外部资源等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

175

2023.11.23

java中void的含义
java中void的含义

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

97

2025.11.27

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

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

1018

2023.10.19

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

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

63

2025.10.17

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

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

407

2025.12.29

java数据库连接教程大全
java数据库连接教程大全

本专题整合了java数据库连接相关教程,阅读专题下面的文章了解更多详细内容。

20

2026.01.15

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
10分钟--Midjourney创作自己的漫画
10分钟--Midjourney创作自己的漫画

共1课时 | 0.1万人学习

Midjourney 关键词系列整合
Midjourney 关键词系列整合

共13课时 | 0.9万人学习

AI绘画教程
AI绘画教程

共2课时 | 0.2万人学习

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

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