首页 > 后端开发 > C++ > 正文

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

冰火之心
发布: 2025-12-17 15:14:02
原创
459人浏览过
线程安全队列需用互斥锁保障操作原子性,条件变量实现阻塞等待,移动语义减少拷贝,可选超时与关闭机制提升鲁棒性。

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,避免数据竞争且无需额外锁
基本上就这些。锁保安全,条件变量管等待,移动提效率,超时与关闭增鲁棒性——组合起来就是一个工业级可用的线程安全队列。

以上就是c++++如何实现一个线程安全的队列_c++锁与条件变量的应用【多线程】的详细内容,更多请关注php中文网其它相关文章!

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

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

下载
来源:php中文网
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn
最新问题
开源免费商场系统广告
热门教程
更多>
最新下载
更多>
网站特效
网站源码
网站素材
前端模板
关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

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