讲师中心 微信公众号
AI工具推荐 视频效率加速

C++实现简单线程池 _ std::condition_variable与任务队列【源码】

夜枫大大_9497

夜枫大大_9497

发布时间:2026-04-09 22:15:15

|

793人浏览过

|

来源于php中文网

原创

线程池防死锁关键在于任务队列、互斥锁与condition_variable的协作:需用while循环检查谓词防虚假唤醒,stop_用atomic_bool,enqueue时短锁+notify_one,析构时先置stop_再notify_all后join,避免detach导致未定义行为。

c++实现简单线程池 _ std::condition_variable与任务队列【源码】

线程池核心结构怎么组织才不会死锁

关键在于任务队列、互斥锁和 std::condition_variable 的协作顺序。常见错误是先加锁再等待条件变量,但没在循环中检查谓词(predicate),导致虚假唤醒后直接消费空队列——触发 front() 或 pop() 崩溃。

正确做法是把任务取用逻辑包在 while 循环里,每次唤醒都重新验证队列非空:

std::unique_lock<std::mutex> lock(mtx_);
cond_.wait(lock, [this] { return !tasks_.empty() || stop_; });
if (stop_ && tasks_.empty()) break;
auto task = std::move(tasks_.front());
tasks_.pop();
  • stop_ 是原子布尔量,用于通知所有工作线程退出
  • 必须用 std::move 拿走任务,避免拷贝开销(尤其任务是 std::function<void()> 时)
  • 不能把 lock 生命周期拉长到任务执行期间——否则整个线程池被一个慢任务阻塞

如何安全地往队列 push 任务并唤醒线程

用户调用 enqueue() 时,只应持有最短必要时间的锁。重点不是“唤醒几个”,而是“至少唤醒一个”:用 notify_one() 即可,除非你明确需要广播(比如批量提交后等全部完成)。滥用 notify_all() 会引发惊群效应,尤其在线程数多于 CPU 核心时反而降低吞吐。

典型实现片段:

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

C++ Code Review Master
C++ Code Review Master

组合式C++代码评审方案,融合静态分析、AI推理、多轮迭代评审和C++专项检查,适用于PR审查、增量代码审查、全项目评审和代码质量评分,触发词包括review cpp、cpp代码评审、C++review、代码审查。

下载
void enqueue(Task&& task) {
    {
        std::unique_lock<std::mutex> lock(mtx_);
        if (stop_) return;
        tasks_.emplace(std::forward<Task>(task));
    }
    cond_.notify_one(); // 在锁外 notify,避免唤醒后立即抢锁
}
  • 锁的作用域严格限制在修改队列的几行,notify_one() 放在锁外更高效
  • 入队前检查 stop_,防止停止过程中仍接收新任务
  • 使用 std::forward 完美转发,兼容左值/右值 Task

为什么析构函数里要调用 join() 而不是 detach()

因为线程池对象销毁时,工作线程可能还在访问其成员(如 tasks_、mtx_、cond_)。若提前 detach(),这些资源会被释放,导致未定义行为——常见表现为 std::terminate 或随机段错误。

标准做法是在析构中先置位 stop_ = true,再 notify_all() 唤醒全部线程,最后对每个 std::thread 调用 join():

~ThreadPool() {
    {
        std::unique_lock<std::mutex> lock(mtx_);
        stop_ = true;
    }
    cond_.notify_all();
    for (auto& t : workers_) t.join();
}
  • stop_ 必须是 std::atomic_bool,否则多线程读写非原子变量是未定义行为
  • 不能在持有 mtx_ 时调用 join(),否则可能死锁(工作线程也在等同一把锁)
  • 如果构造时线程数为 0,workers_ 为空,join() 循环不执行,安全

std::function 作为任务类型有什么隐含成本

它方便但有两层开销:一是类型擦除带来的堆分配(除非编译器做了 small function optimization),二是调用时的虚函数跳转。对高频小任务(如每毫秒调度一次计数器),这会明显拖慢性能。

替代思路:用模板参数约束任务类型,或改用函数指针 + void* 参数(需手动管理生命周期);但多数场景下 std::function 的简洁性更值得保留。

  • 避免捕获大对象进 lambda:比如按值捕获 std::vector<int>(10000),每次 enqueue 都触发一次拷贝
  • 若任务需返回值,不要直接存 std::packaged_task<T()> 到队列——它不可拷贝,要用 std::move 构造
  • 调试时注意:GCC/Clang 的 -fsanitize=thread 可捕获任务中对已销毁对象的访问

真正难处理的是任务内部抛异常。线程池默认不捕获,会导致整个程序终止。如果需要容错,得在工作线程循环里加 try/catch(...) 并记录日志——这点几乎总被忽略。

热门AI工具

更多
立刻MV
立刻MV Hot

立刻MV是一款AI文本写作工具,AI 音乐视频(MV)创作工具。

AionClaw
AionClaw Hot

AionClaw是一款面向办公、创作和编程任务的AI桌面智能体。

墨刀AI
墨刀AI Hot

一款AI图像与设计工具,主要用于产品经理的专属智能体,适合需要提升相关任务效率的用户。

火山引擎

火山引擎是一款面向企业的云计算与AI服务平台。

DeepSeek

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

SkildArt
SkildArt Hot

SkildArt是一款AI文本写作工具,一站式 AI 视觉创作平台。

PixPix
PixPix Hot

PixPix是一款面向电商视觉生产的AI商品图生成工具。

WorkBuddy

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

豆包大模型

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

相关专题

更多
while的用法
while的用法

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

334

2023.09.25

string转int
string转int

在编程中,我们经常会遇到需要将字符串(str)转换为整数(int)的情况。这可能是因为我们需要对字符串进行数值计算,或者需要将用户输入的字符串转换为整数进行处理。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

5699

2023.08.02

int占多少字节
int占多少字节

int占4个字节,意味着一个int变量可以存储范围在-2,147,483,648到2,147,483,647之间的整数值,在某些情况下也可能是2个字节或8个字节,int是一种常用的数据类型,用于表示整数,需要根据具体情况选择合适的数据类型,以确保程序的正确性和性能。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2845

2024.08.29

c++怎么把double转成int
c++怎么把double转成int

本专题整合了 c++ double相关教程,阅读专题下面的文章了解更多详细内容。

3568

2025.08.29

C++中int的含义
C++中int的含义

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

2525

2025.08.29

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

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

636

2023.11.23

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

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

351

2025.11.27

lambda表达式
lambda表达式

Lambda表达式是一种匿名函数的简洁表示方式,它可以在需要函数作为参数的地方使用,并提供了一种更简洁、更灵活的编码方式,其语法为“lambda 参数列表: 表达式”,参数列表是函数的参数,可以包含一个或多个参数,用逗号分隔,表达式是函数的执行体,用于定义函数的具体操作。本专题为大家提供lambda表达式相关的文章、下载、课程内容,供大家免费下载体验。

911

2023.09.15

LLVM自定义Pass怎么写
LLVM自定义Pass怎么写

本专题聚焦LLVM自定义Pass开发,整理Pass类结构、run()方法、PreservedAnalyses、CMake构建、插件注册、-load-pass-plugin加载和测试用例编写流程。

80

2026.09.30

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Conan 2 Essentials 免费课程
Conan 2 Essentials 免费课程

共0课时 | 0人学习

CMake 与 Conan 集成实践
CMake 与 Conan 集成实践

共0课时 | 0人学习

Conan 2 高级依赖模型介绍
Conan 2 高级依赖模型介绍

共0课时 | 0人学习

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

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