线程池通过预先创建线程并复用以减少开销，提升并发性能；c++中利用std::Thread、std::queue、std::mutex和std::condition_variable可实现基本线程池，包含工作线程、任务队列、同步机制与生命周期管理；示例代码展示了一个支持返回值的线程池实现，构造时启动指定数量线程，任务通过enqueue提交并返回std::future，析构时自动回收资源；使用注意包括异常处理、动态调整线程数、无锁队列优化及空闲超时退出等。
线程池的核心思想是提前创建一批线程，避免频繁创建和销毁线程带来的开销。任务提交后由空闲线程处理，提升程序并发性能。C++中可通过标准库的 std::thread、std::queue、std::mutex 和 std::condition_variable 实现一个基础线程池。
线程池基本原理
线程池包含以下关键组件：
- 工作线程：固定数量的线程在后台等待任务。
- 任务队列：存放待执行的任务（通常为函数对象）。
- 同步机制：使用互斥锁保护共享数据，条件变量实现线程阻塞与唤醒。
- 生命周期管理：控制线程池启动、关闭和资源回收。
C++ 线程池实现示例
下面是一个简洁可运行的线程池实现：
立即学习“C++免费学习笔记（深入）”；
#include <iostream> #include <vector> #include <queue> #include <thread> #include <functional> #include <mutex> #include <condition_variable> #include <future> <p>class ThreadPool { public: explicit ThreadPool(size_t numThreads) : stop(false) { for (size_t i = 0; i < numThreads; ++i) { workers.emplace_back([this] { while (true) { std::function<void()> task; { std::unique_lock<std::mutex> lock(queue_mutex); condition.wait(lock, [this] { return stop || !tasks.empty(); }); if (stop && tasks.empty()) return; task = std::move(tasks.front()); tasks.pop(); } task(); } }); } }</p><pre class='brush:php;toolbar:false;'>template<class F> auto enqueue(F&& f) -> std::future<typename std::invoke_result_t<F>> { using return_type = typename std::invoke_result_t<F>; auto task = std::make_shared<std::packaged_task<return_type()>>( std::forward<F>(f) ); std::future<return_type> res = task->get_future(); { std::unique_lock<std::mutex> lock(queue_mutex); if (stop) throw std::runtime_error("enqueue on stopped ThreadPool"); tasks.emplace([task]() { (*task)(); }); } condition.notify_one(); return res; } ~ThreadPool() { { std::unique_lock<std::mutex> lock(queue_mutex); stop = true; } condition.notify_all(); for (std::thread &worker : workers) worker.join(); }private: std::vector<std::thread> workers; std::queue<std::function<void()>> tasks;
std::mutex queue_mutex; std::condition_variable condition; bool stop;};
使用示例
演示如何提交任务并获取返回值：
立即学习“C++免费学习笔记（深入）”；
int main() { ThreadPool pool(4); // 创建4个线程的线程池 <pre class='brush:php;toolbar:false;'>std::vector<std::future<int>> results; for (int i = 0; i < 8; ++i) { results.emplace_back( pool.enqueue([i] { std::this_thread::sleep_for(std::chrono::seconds(1)); std::cout << "Task " << i << " running on thread " << std::this_thread::get_id() << 'n'; return i * i; }) ); } // 获取结果 for (auto& result : results) { std::cout << "Result: " << result.get() << 'n'; } return 0;}
该实现支持任意可调用对象，并通过 std::future 返回执行结果。构造时启动指定数量的工作线程，析构时自动等待所有任务完成并回收资源。
注意事项与优化方向
实际使用中需注意：
- 避免在任务中抛出未捕获异常，可能导致线程退出。
- 可根据负载动态调整线程数，而非固定大小。
- 高频率小任务场景下，可考虑无锁队列提升性能。
- 长时间空闲线程可设置超时退出，节省资源。
基本上就这些。这个线程池虽简单，但已具备核心功能，适合学习和中小型项目使用。