线程池通过预先创建线程并复用以减少开销，提升并发性能；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 返回执行结果。构造时启动指定数量的工作线程，析构时自动等待所有任务完成并回收资源。
注意事项与优化方向
实际使用中需注意：
- 避免在任务中抛出未捕获异常，可能导致线程退出。
- 可根据负载动态调整线程数，而非固定大小。
- 高频率小任务场景下，可考虑无锁队列提升性能。
- 长时间空闲线程可设置超时退出，节省资源。
基本上就这些。这个线程池虽简单，但已具备核心功能，适合学习和中小型项目使用。
