0

0

C++ 怎么实现简单的线程池 C++ task queue与worker thread模型【并发编程】

冰火之心

冰火之心

发布时间:2026-01-29 13:55:34

|

204人浏览过

|

来源于php中文网

原创

最小可用线程池核心是:任务队列(std::queue)、工作线程循环(wait→pop→exec)、线程安全控制(std::mutex+std::condition_variable);stop_requested需为std::atomic,入队出队必须加锁,notify_one防惊群,谓词等待防虚假唤醒。

c++ 怎么实现简单的线程池 c++ task queue与worker thread模型【并发编程】

怎么用 std::threadstd::queue 搭出最小可用线程池

核心就三块:任务队列、工作线程循环、线程安全控制。别一上来就想封装成模板类,先跑通最简逻辑。

关键点是用 std::queue<:function>> 存任务,配合 std::mutex + std::condition_variable 实现阻塞取任务。每个 worker 线程死循环:wait → pop → exec

  • 任务入队必须加锁,且通知条件变量:cv.notify_one()(不是 notify_all,避免惊群)
  • worker 循环里要用 cv.wait(lock, [&]{ return !tasks.empty() || stop_requested; }); 配合谓词防止虚假唤醒
  • 停止信号(stop_requested)要 std::atomic,否则可能读不到最新值

为什么不能直接用 std::queue 而不加锁

因为 std::queue::push()std::queue::pop() 都不是原子操作——哪怕只改一个指针,在多线程下也存在竞态。典型表现是程序偶尔崩溃在 queue::front()queue::empty() 返回假阳性。

更隐蔽的问题是内存重排:push() 写入新节点后,其他线程可能因缓存未同步而看不到该节点,导致无限等待。所以必须用 std::mutex 保护整个入队/出队临界区,或改用无锁队列(如 boost::lockfree::queue,但复杂度陡增)。

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

MusicLM
MusicLM

谷歌平台的AI作曲工具,用文字生成音乐

下载

std::packaged_task 怎么和线程池一起用

它能把任意可调用对象(lambda、函数指针、绑定表达式)转成可拷贝、可存储的 task,并自带 std::future,适合需要返回值的场景。

入队时包装一下:

auto task = std::make_shared>([&]{ return heavy_work(); });
tasks.push([task]{ (*task)(); });
然后用 task->get_future().get() 获取结果。注意:不要直接 push std::packaged_task 对象进 queue(它不可拷贝),必须用 std::shared_ptr 包一层。

  • 如果任务抛异常,std::future::get() 会 rethrow,务必捕获
  • 大量短任务时,std::packaged_task 的内存分配开销比裸 std::function 明显,别无脑套

线程数设多少才合理

没有银弹。CPU 密集型任务:线程数 ≈ std::thread::hardware_concurrency();IO 密集型可适当上浮(比如 ×1.5),但超过 2× 后吞吐常不升反降——上下文切换成本压倒收益。

真正容易被忽略的是:线程池生命周期管理。别让 worker 线程持有外部对象引用(尤其是 this 指针),否则析构时可能访问已释放内存。推荐在析构函数里先置 stop_requested = true,再调用 cv.notify_all(),最后对每个 std::thread 调用 join()(千万别 detach)。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
lambda表达式
lambda表达式

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

207

2023.09.15

python lambda函数
python lambda函数

本专题整合了python lambda函数用法详解,阅读专题下面的文章了解更多详细内容。

191

2025.11.08

Python lambda详解
Python lambda详解

本专题整合了Python lambda函数相关教程,阅读下面的文章了解更多详细内容。

55

2026.01.05

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

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

503

2023.08.10

Python 多线程与异步编程实战
Python 多线程与异步编程实战

本专题系统讲解 Python 多线程与异步编程的核心概念与实战技巧,包括 threading 模块基础、线程同步机制、GIL 原理、asyncio 异步任务管理、协程与事件循环、任务调度与异常处理。通过实战示例,帮助学习者掌握 如何构建高性能、多任务并发的 Python 应用。

166

2025.12.24

java多线程相关教程合集
java多线程相关教程合集

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

15

2026.01.21

C++多线程相关合集
C++多线程相关合集

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

15

2026.01.21

Java 并发编程高级实践
Java 并发编程高级实践

本专题深入讲解 Java 在高并发开发中的核心技术,涵盖线程模型、Thread 与 Runnable、Lock 与 synchronized、原子类、并发容器、线程池(Executor 框架)、阻塞队列、并发工具类(CountDownLatch、Semaphore)、以及高并发系统设计中的关键策略。通过实战案例帮助学习者全面掌握构建高性能并发应用的工程能力。

87

2025.12.01

java入门学习合集
java入门学习合集

本专题整合了java入门学习指南、初学者项目实战、入门到精通等等内容,阅读专题下面的文章了解更多详细学习方法。

1

2026.01.29

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
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号