展开菜单
首页 精品内容 本月促销 装机必备 Windows macOS软件 IOS软件 Android AI PDF教程 专题
全部分类

当前位置:

首页 > 编程开发 > C++实现线程安全的优先级队列 _ std::mutex与堆排算法封装【源码】

C++实现线程安全的优先级队列 _ std::mutex与堆排算法封装【源码】

用std::mutex封装堆可实现线程安全,但只读操作(top、empty、size)也需加锁防读中间态。pop_heap后须紧跟pop_back。top返回的引用锁释放后失效。生产者-消费者模型需额外条件变量。

直接说结论:用 `std::mutex` 把堆操作包起来,确实可以实现线程安全,但千万不能只锁 `push` 和 `pop` 这两个函数——`top()`、`empty()`、`size()` 这些看似只读的操作,同样需要上锁。否则,你很容易读到中间态的数据,甚至直接引发竞态崩溃。 ### 为什么 `std::priority_queue` 本身不线程安全 `std::priority_queue` 是一个容器适配器,底层默认使用 `std::vector`,再加上 `std::make_heap`、`std::push_heap`、`std::pop_heap` 这些算法来维护堆结构。问题就出在这里:这些函数操作的是裸内存,没有任何同步机制。假如一个线程刚调完 `push_heap`,还没来得及更新底层容器的 `size`,另一个线程恰好来读 `top()`,那它拿到的可能是一个未初始化的尾元素。 实践中常见的错误现象有: * 抛出 `std::out_of_range` 异常或直接访问违规(因为 `top()` 返回的是底层 `vector` 的引用,而 `size` 已经混乱了)。 * 两次连续调用 `top()`,结果返回的值不一样(因为另一个线程正在执行 `pop` 操作,正处于半路)。 * 调用 `empty()` 返回 `false`,但紧接着 `pop()` 就报错了——元素已经被其他线程抢先取走了。 ### 封装时必须加锁的操作 不是“增删查”里只锁增删就够了——所有需要访问内部容器状态的函数,都得进入同一把 `std::mutex` 的保护范围。具体来说: * **`push()`**:从调用 `c.push_back()` 到执行 `std::push_heap`,整个流程不可分割。 * **`pop()`**:必须先 `std::pop_heap`,再 `c.pop_back()`,两步缺一不可,且必须一气呵成。 * **`top()`**:返回 `c.front()`,此时必须保证没有其他线程在修改 `c`。 * **`empty()` 和 `size()`**:读 `c.size()` 看起来是只读的,但假如另一个线程正在执行 `pop_back()`,就可能读到撕裂值。在 debug 模式下,`vector` 的迭代器检查会更敏感,问题更容易暴露。 别想着用 `std::shared_mutex` 来做读写分离优化——`std::make_heap` 这类算法会重排整个容器,读操作和写操作根本没法真正并发,硬要分离反而只会徒增锁的开销。 ### 关键代码片段与易错点 下面是一个典型的封装结构(省略模板参数,聚焦同步逻辑): ```cpp template, typename Compare = std::less> class thread_safe_priority_queue { mutable std::mutex mtx; Container c; Compare comp; public: void push(const T& value) { std::lock_guard lock(mtx); c.push_back(value); std::push_heap(c.begin(), c.end(), comp); // 注意:comp 必须可拷贝或无状态 } void pop() { std::lock_guard lock(mtx); std::pop_heap(c.begin(), c.end(), comp); // 堆顶移到末尾 c.pop_back(); // 再删末尾 } const T& top() const { std::lock_guard lock(mtx); return c.front(); // 用 c.front() 而不是 c.at(0),避免 bounds check 开销 } bool empty() const { std::lock_guard lock(mtx); return c.empty(); } }; ``` 这里面有几个容易踩的坑: 1. **`std::pop_heap` 不删除元素**,必须紧跟一个 `c.pop_back()`。如果漏掉后者,容器的 `size` 会不断膨胀,后续再调 `push_heap` 就可能导致未定义行为。 2. **比较对象 `comp` 的生命周期问题**。如果它捕获了外部局部变量(比如用 lambda 表达式),多线程下极易产生悬挂引用。 3. 不要在锁内做耗时操作,比如日志输出或网络调用,否则整个队列会被阻塞住。另外,`top()` 返回的是引用,锁释放后这个引用就失效了——这一点必须清楚地写进文档里。 最后提醒一点:上面这个封装只解决了基本的线程安全问题。如果队列用在生产者-消费者模型中,`pop()` 在队列为空时应该阻塞等待,而不是直接崩溃。这需要额外引入 `std::condition_variable`,并且 `wait` 的 predicate 必须和 `mutex` 配合检查队列状态,否则惊群效应和虚假唤醒的问题一个都躲不掉。
本文内容来源于互联网,如有侵权请联系删除。
作者最新文章
编程开发 C++
相关文章 更多
精品专题 更多
本月促销

正软商城本月促销专区,汇集办公、设计、安全、影音、系统工具及AI软件等正版软件优惠活动,提供限时折扣、特价授权和优惠购买信息,活动库存及价格以页面实时展示为准。

装机必备

正软商城装机必备专区,精选办公、浏览器、安全防护、影音播放、压缩解压、设计创作和系统工具等电脑常用正版软件,帮助用户快速完成新电脑软件配置。

Windows

正软商城Windows软件专区,汇集适用于Windows电脑的办公、设计、安全防护、影音播放、开发工具和系统优化软件,提供软件介绍、系统要求、正版授权及购买下载服务。

macOS软件

正软商城macOS软件专区,精选适用于Mac电脑的办公、设计、影音、效率、开发和系统工具,提供软件功能介绍、macOS兼容版本、正版授权及购买下载服务。

IOS软件

正软商城iOS软件专区,精选适用于iPhone和iPad的办公、学习、影音、设计、效率及AI应用,提供功能介绍、适用设备、系统要求和正版获取方式等信息。

AI

正软商城AI软件专区,汇集AI写作、AI绘画、AI视频、AI办公、AI编程、AI翻译、智能客服和数据分析等人工智能工具,提供功能介绍、适用平台、收费方式及正版购买信息。

PDF教程

正软商城PDF教程频道提供PDF编辑、转换、合并、拆分、压缩及格式处理方法,同时介绍常用PDF软件和工具的使用技巧。

Mac软件 更多
灵活计算器
灵活计算器

灵活计算器是一款笔记式算数应用,支持实时计算、动态关联和云端同步功能。记录、整理和输出之间的过渡会更自然,适合长期写作、做笔记或持续沉淀个人内容。

赤友清理大师
赤友清理大师

赤友清理大师是一款为 Mac 设计的智能清理优化工具,可精准扫描垃圾、大文件、重复文件等,释放磁盘空间。做扫描整理、文字提取和表格转换时,它能把识别后的处理步骤接得更顺,资料录入这类场景会省下不少时间。

极度公式
极度公式

极度公式是一款跨平台专业LaTeX公式识别编辑软件,支持OCR公式识别和多平台编辑。和使用说明,避免使用,享受完整功能与稳定支持。做扫描整理、文字提取和表格转换时,它能把识别后的处理步骤接得更顺,资料录入这类场景会省下不少时间。

图几
图几

图几是一款适用于 macOS 的截图、标注与美化工具,支持离线操作保障隐私。界面整理和高频系统操作被放到一起考虑,桌面或窗口内容一多时,管理起来会更省心。

密码键盘
密码键盘

密码键盘是一款兼具安全性与便捷性的高效密码管理器。日常使用里的持续防护和信息管理会更突出,适合把安全控制放进长期使用流程中的场景。

思源笔记
思源笔记

思源笔记是一款本地笔记软件,提供所见即所得的编辑方式,为长文写作带来顺滑的体验。记录、整理和输出之间的过渡会更自然,适合长期写作、做笔记或持续沉淀个人内容。

Office 365 简体中文
Office 365 简体中文

一款文字处理软件,一种订阅式的跨平台办公软件,基于云平台提供多种服务,通过将 Excel 和 Outlook 等应用与 OneDrive 和 Microsoft Teams 等强大的云服务相结合,Office 365 可让任何人使用任何设备随时随地创建和共享内容。

WALTR PRO
WALTR PRO

WALTR是一款电脑至iOS文件传输转换工具,操作简单,快速实现文件识别与传送。做扫描整理、文字提取和表格转换时,它能把识别后的处理步骤接得更顺,资料录入这类场景会省下不少时间。

CodeExpander
CodeExpander

CodeExpander 是一款快捷短语输入增强工具,通过键入缩写自动展开为自定义文段,提升工作效率。任务管理和过程控制会更完整,持续下载、批量同步或需要稳定传输流程的场景会更适合它。

Mountain Duck
Mountain Duck

Mountain Duck 是一款能将多个网盘挂载到本地的工具,像本地磁盘一样使用网盘。清理链路的完整性会更好一些,做应用卸载、残留处理和空间整理时,通常能少走很多手动排查步骤。

Menuist
Menuist

Menuist 是一款面向 macOS 的 Finder 右键菜单增强工具,主要用来补充新建文件、快捷导航等常用操作,让日常文件管理和访问路径时更高效、更顺手。

Mole
Mole

Mole 是一款专为 Mac 设计的深度清理优化工具,涵盖缓存清理、应用管理及实时状态监控等功能。清理链路的完整性会更好一些,做应用卸载、残留处理和空间整理时,通常能少走很多手动排查步骤。

WINDOWS 更多
Windows 10
Windows 10

Windows 10 是一款微软推出的经典操作系统,拥有硬件兼容性与多任务处理能力。它更偏向把系统状态查看和常用调节动作放在一起,适合需要持续观察和微调设备状态的场景。

极度公式
极度公式

极度公式是一款跨平台专业LaTeX公式识别编辑软件,支持OCR公式识别和多平台编辑。和使用说明,避免使用,享受完整功能与稳定支持。做扫描整理、文字提取和表格转换时,它能把识别后的处理步骤接得更顺,资料录入这类场景会省下不少时间。

密码键盘
密码键盘

密码键盘是一款兼具安全性与便捷性的高效密码管理器。日常使用里的持续防护和信息管理会更突出,适合把安全控制放进长期使用流程中的场景。

思源笔记
思源笔记

思源笔记是一款本地笔记软件,提供所见即所得的编辑方式,为长文写作带来顺滑的体验。记录、整理和输出之间的过渡会更自然,适合长期写作、做笔记或持续沉淀个人内容。

傲梅轻松备份
傲梅轻松备份

傲梅轻松备份是一款专业易用的数据备份软件,为重要数据提供安全保障。日常使用里的持续防护和信息管理会更突出,适合把安全控制放进长期使用流程中的场景。

Office 365 简体中文
Office 365 简体中文

一款文字处理软件,一种订阅式的跨平台办公软件,基于云平台提供多种服务,通过将 Excel 和 Outlook 等应用与 OneDrive 和 Microsoft Teams 等强大的云服务相结合,Office 365 可让任何人使用任何设备随时随地创建和共享内容。

Wise Folder Hider Pro
Wise Folder Hider Pro

Wise Folder Hider Pro 是一款专业级文件和文件夹隐藏加密软件,为私密数据添加多重保护。高频操作更强调就近处理,浏览、整理和跨目录移动文件时,来回切换和重复点击都会少很多。

WALTR PRO
WALTR PRO

WALTR是一款电脑至iOS文件传输转换工具,操作简单,快速实现文件识别与传送。做扫描整理、文字提取和表格转换时,它能把识别后的处理步骤接得更顺,资料录入这类场景会省下不少时间。

CodeExpander
CodeExpander

CodeExpander 是一款快捷短语输入增强工具,通过键入缩写自动展开为自定义文段,提升工作效率。任务管理和过程控制会更完整,持续下载、批量同步或需要稳定传输流程的场景会更适合它。

PinStack
PinStack

PinStack是一款轻量级的Windows平台剪贴板管理工具,优化您的剪贴板使用体验。它更偏向把系统状态查看和常用调节动作放在一起,适合需要持续观察和微调设备状态的场景。

Mountain Duck
Mountain Duck

Mountain Duck 是一款能将多个网盘挂载到本地的工具,像本地磁盘一样使用网盘。清理链路的完整性会更好一些,做应用卸载、残留处理和空间整理时,通常能少走很多手动排查步骤。

Seer
Seer

Seer是一款在Win平台下的空格键功能增强效率工具,只需轻敲空格键,就能预览几乎任何格式的文件。它更适合把零散的小功能集中起来使用,处理高频琐碎任务时会更省事。