c++中如何实现一个线程池_线程池原理与C++实现示例讲解

新闻中心 NEWS CENTER

您当前位置：首页 > 新闻中心 > 网络学院

c++中如何实现一个线程池_线程池原理与C++实现示例讲解

2025-10-28

浏览次数：次

返回列表

线程池通过预先创建线程并复用以减少开销，提升并发性能；C++中利用std::thread、std::queue、std::mutex和std::condition_variable可实现基本线程池，包含工作线程、任务队列、同步机制与生命周期管理；示例代码展示了一个支持返回值的线程池实现，构造时启动指定数量线程，任务通过enqueue提交并返回std::future，析构时自动回收资源；使用注意包括异常处理、动态调整线程数、无锁队列优化及空闲超时退出等。

c++中如何实现一个线程池_线程池原理与c++实现示例讲解

线程池的核心思想是提前创建一批线程，避免频繁创建和销毁线程带来的开销。任务提交后由空闲线程处理，提升程序并发性能。C++中可通过标准库的 std::thread、std::queue、std::mutex 和 std::condition_variable 实现一个基础线程池。

线程池基本原理

线程池包含以下关键组件：

工作线程：固定数量的线程在后台等待任务。
任务队列：存放待执行的任务（通常为函数对象）。
同步机制：使用互斥锁保护共享数据，条件变量实现线程阻塞与唤醒。
生命周期管理：控制线程池启动、关闭和资源回收。

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<:thread> workers; std::queue<:function>> tasks;

std::mutex queue_mutex;
std::condition_variable condition;
bool stop;

};

使用示例

演示如何提交任务并获取返回值：

Musho

AI网页设计Figma插件

76 查看详情 Musho

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 返回执行结果。构造时启动指定数量的工作线程，析构时自动等待所有任务完成并回收资源。