C++线程池实现包含阻塞任务队列、工作线程组、停止标志、条件变量和互斥锁；支持任意可调用对象入队，返回future获取结果，析构时安全等待并停止所有线程。
用C++实现一个轻量、实用的线程池，核心是管理一组复用的工作线程，配合任务队列和同步机制。下面是一个基于 std::thread、std::queue、std::mutex 和 std::condition_variable 的简洁实现，支持任意可调用对象（lambda、函数指针、bind等），并具备安全停止功能。
线程池的基本结构设计
一个最小可用线程池需包含：
- 一个阻塞任务队列（线程安全）
- 一组运行中的工作线程
- 控制生命周期的标志（如
m_stop） - 用于唤醒等待线程的条件变量
- 保护共享数据的互斥锁
完整可运行代码示例
以下为 C++11 及以上兼容的实现（无需第三方库）：
立即学习“C++免费学习笔记（深入）”；
#include <iostream>
#include <vector>
#include <queue>
#include <thread>
#include <mutex>
#include <condition_variable>
#include <functional>
#include <future>
<p>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<void()> task;
{
std::unique_lock<std::mutex> 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();
}
});
}
}</p><pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">template<class F, class... Args>
auto enqueue(F&& f, Args&&... args)
-> std::future<typename std::result_of<F(Args...) >::type> {
using return_type = typename std::result_of<F(Args...) >::type;
auto task = std::make_shared<std::packaged_task<return_type()>>(
std::bind(std::forward<F>(f), std::forward<Args>(args)...)
);
std::future<return_type> res = task->get_future();
{
std::unique_lock<std::mutex> 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_lock<std::mutex> 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<std::thread> m_workers; std::queue<std::function<void()>> 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；避免在任务中持有线程池自身的引用，防止循环依赖和析构死锁。
