C++线程池实现包含阻塞任务队列、工作线程组、停止标志、条件变量和互斥锁；支持任意可调用对象入队，返回future获取结果，析构时安全等待并停止所有线程。

用C++实现一个轻量、实用的线程池，核心是管理一组复用的工作线程，配合任务队列和同步机制。下面是一个基于 std::thread、std::queue、std::mutex 和 std::condition_variable 的简洁实现，支持任意可调用对象（lambda、函数指针、bind等），并具备安全停止功能。

线程池的基本结构设计

一个最小可用线程池需包含：

• 一个阻塞任务队列（线程安全）
• 一组运行中的工作线程
• 控制生命周期的标志（如 m_stop）
• 用于唤醒等待线程的条件变量
• 保护共享数据的互斥锁

完整可运行代码示例

以下为 C++11 及以上兼容的实现（无需第三方库）：

#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
class ThreadPool {
public:
explicit ThreadPool(size_t threads) : m_stop(false) {
for (size_t i = 0; i < threads; ++i) {
m_workers.emplace_back([this] {
while (true) {
std::function task;
{
std::unique_lock lock(m_queue_mutex);
m_condition.wait(lock, [this] { return m_stop || !m_tasks.empty(); });
if (m_stop && m_tasks.empty()) return;
task = std::move(m_tasks.front());
m_tasks.pop();
}
task();
}
});
}
}
templatezuojiankuohaophpcnclass F, class... Argsyoujiankuohaophpcn
auto enqueue(F&& f, Args&&... args) 
    -youjiankuohaophpcn std::futurezuojiankuohaophpcntypename std::result_ofzuojiankuohaophpcnF(Args...) youjiankuohaophpcn::typeyoujiankuohaophpcn {
    using return_type = typename std::result_ofzuojiankuohaophpcnF(Args...) youjiankuohaophpcn::type;

    auto task = std::make_sharedzuojiankuohaophpcnstd::packaged_taskzuojiankuohaophpcnreturn_type()youjiankuohaophpcnyoujiankuohaophpcn(
        std::bind(std::forwardzuojiankuohaophpcnFyoujiankuohaophpcn(f), std::forwardzuojiankuohaophpcnArgsyoujiankuohaophpcn(args)...)
    );

    std::futurezuojiankuohaophpcnreturn_typeyoujiankuohaophpcn res = task-youjiankuohaophpcnget_future();
    {
        std::unique_lockzuojiankuohaophpcnstd::mutexyoujiankuohaophpcn lock(m_queue_mutex);
        if (m_stop) throw std::runtime_error("enqueue on stopped ThreadPool");
        m_tasks.emplace([task]() { (*task)(); });
    }
    m_condition.notify_one();
    return res;
}

~ThreadPool() {
    {
        std::unique_lockzuojiankuohaophpcnstd::mutexyoujiankuohaophpcn lock(m_queue_mutex);
        m_stop = true;
    }
    m_condition.notify_all();
    for (std::thread &t : m_workers) {
        if (t.joinable()) t.join();
    }
}
private:
std::vector<:thread> m_workers;
std::queue<:function>> m_tasks;
std::mutex m_queue_mutex;
std::condition_variable m_condition;
bool m_stop;
};
如何使用线程池提交任务
支持无返回值和带返回值两种常见场景：
无返回值任务：
ThreadPool pool(4);
pool.enqueue([]{ std::cout << "Hello from thread\n"; });
带返回值任务（自动获取 future）：
auto result = pool.enqueue([](int a, int b) { return a + b; }, 10, 20);
std::cout << result.get() << "\n"; // 输出 30
捕获局部变量的 lambda：
int x = 42;
auto fut = pool.enqueue([x]{ return x * 2; });
std::cout << fut.get() << "\n"; // 输出 84
注意事项与改进方向
该实现在教学和中小型项目中足够稳健，但生产环境可考虑：

任务优先级支持（改用优先队列）
空闲线程超时回收（避免常驻过多线程）
任务取消机制（需在 callable 中主动检查中断标记）
更细粒度的异常传播（当前异常会终止 worker 线程）
使用 std::jthread（C++20）简化析构时 join 逻辑

不复杂但容易忽略：确保所有任务对象在线程池销毁前完成，或显式等待 future；避免在任务中持有线程池自身的引用，防止循环依赖和析构死锁。
          


# ai 
# c++ 
# ios 
# stream 
# 同步机制 
# red 
# 局部变量 
# bool 
# void 
# 循环 
# Lambda 
# 指针 
# private 
# 线程 
# 多线程 
# Thread 
# function 
# 对象 
# 返回值 
# 死锁 
# 是一个 
# 互斥 
# 两种 
# 第三方 
# 如何使用 
# 复用 
# 并具备 
# 细粒度 
 




相关栏目：
    【
        网站优化151355    】
    【
        网络推广146373    】
    【
        网络技术251813    】
    【
        AI营销90571    】




相关推荐：
 如何用手机制作网站和网页,手机移动端的网站能制作成中英双语的吗？ 
Laravel如何记录日志_Laravel Logging系统配置与自定义日志通道 
Laravel如何配置中间件Middleware_Laravel自定义中间件拦截请求与权限校验【步骤】 
高防服务器：AI智能防御DDoS攻击与数据安全保障 
Laravel请求验证怎么写_Laravel Validator自定义表单验证规则教程 
如何在企业微信快速生成手机电脑官网？ 
MySQL查询结果复制到新表的方法(更新、插入) 
 成都网站制作公司哪家好,四川省职工服务网是做什么用？ 
关于BootStrap modal 在IOS9中不能弹出的解决方法(IOS 9 bootstrap modal ios 9 noticework) 
 独立制作一个网站多少钱,建立网站需要花多少钱？ 
Laravel如何处理和验证JSON类型的数据库字段 
Laravel如何配置和使用缓存？（Redis代码示例） 
Linux网络带宽限制_tc配置实践解析【教程】 
如何为不同团队 ID 动态生成多个非值班状态按钮 
如何用PHP快速搭建CMS系统？ 
 矢量图网站制作软件,用千图网的一张矢量图做公司app首页，该网站并未说明版权等问题，这样做算不算侵权？应该如何解决？ 
LinuxCD持续部署教程_自动发布与回滚机制 
Laravel如何集成微信支付SDK_Laravel使用yansongda-pay实现扫码支付【实战】 
Windows Hello人脸识别突然无法使用 
Edge浏览器如何截图和滚动截图_微软Edge网页捕获功能使用教程【技巧】 
Laravel怎么实现验证码功能_Laravel集成验证码库防止机器人注册 
 深圳网站制作培训,深圳哪些招聘网站比较好？ 
Laravel如何构建RESTful API_Laravel标准化API接口开发指南 
javascript如何操作浏览器历史记录_怎样实现无刷新导航 
php中::能调用final静态方法吗_final修饰静态方法调用规则【解答】 
Bootstrap整体框架之JavaScript插件架构 
如何在IIS7上新建站点并设置安全权限？ 
Laravel如何使用Seeder填充数据_Laravel模型工厂Factory批量生成测试数据【方法】 
Laravel事件监听器怎么写_Laravel Event和Listener使用教程 
千问怎样用提示词获取健康建议_千问健康类提示词注意事项【指南】 
Android使用GridView实现日历的简单功能 
如何为不同团队 ID 动态生成多个“认领值班”按钮 
如何在宝塔面板创建新站点？ 
 北京的网站制作公司有哪些,哪个视频网站最好？ 
Laravel如何使用模型观察者？（Observer代码示例） 
Mybatis 中的insertOrUpdate操作 
三星、SK海力士获美批准：可向中国出口芯片制造设备 
Laravel如何使用Service Container和依赖注入？（代码示例） 
如何快速配置高效服务器建站软件？ 
利用 Google AI 进行 YouTube 视频 SEO 描述优化 
Android自定义控件实现温度旋转按钮效果 
android nfc常用标签读取总结 
青岛网站建设如何选择本地服务器？ 
浅谈redis在项目中的应用 
 大连企业网站制作公司,大连2025企业社保缴费网上缴费流程？ 
 制作旅游网站html,怎样注册旅游网站？ 
Laravel如何实现用户角色和权限系统_Laravel角色权限管理机制 
Laravel如何实现邮箱地址验证功能_Laravel邮件验证流程与配置 
laravel怎么在请求结束后执行任务（Terminable Middleware）_laravel Terminable Middleware请求结束任务执行方法 
Laravel API资源(Resource)怎么用_格式化Laravel API响应的最佳实践