C++如何实现线程池_C++ 线程池实现方法-C++-PHP中文网

C++如何实现线程池_C++ 线程池实现方法

裘德小鎮的故事

发布： 2025-10-11 08:20:01

原创

337人浏览过

线程池的核心是复用线程以减少开销，C++中通过std::thread、std::queue、std::mutex、std::condition_variable和std::function实现；包含工作线程集合、任务队列、互斥锁、条件变量和运行控制开关；每个线程循环等待任务，使用std::function<void()>封装任务，通过unique_lock和condition_variable实现线程同步与唤醒；提供enqueue方法提交任务并返回std::future获取结果；析构时设置stop标志，通知所有线程并等待其结束；示例创建4线程池，提交8个任务，输出任务信息并返回计算结果。

c++如何实现线程池_c++ 线程池实现方法

线程池的核心目标是复用线程，避免频繁创建和销毁线程带来的开销。C++ 中可以通过 std::thread、std::queue、std::mutex、std::condition_variable 和函数对象（如 std::function）来实现一个基本的线程池。

1. 线程池的基本结构

一个简单的线程池通常包含以下几个部分：

工作线程集合：一组等待任务的线程。
任务队列：存放待执行的任务（通常是函数对象）。
互斥锁（mutex）：保护任务队列的线程安全。
条件变量（condition_variable）：用于通知空闲线程有新任务到来。
控制开关：标识线程池是否正在运行，用于优雅关闭。

2. 定义任务类型与线程函数

使用 std::function<void()> 来表示任意可调用的任务，比如 lambda、函数指针或 bind 表达式。

每个工作线程在启动后会进入一个循环，从任务队列中取出任务并执行。如果没有任务，就等待条件变量唤醒。

立即学习“C++免费学习笔记（深入）”；

ViiTor实时翻译

AI实时多语言翻译专家！强大的语音识别、AR翻译功能。

116

查看详情

关键逻辑如下：

加锁访问任务队列。
如果队列为空且线程池未关闭，线程等待（condition_variable.wait）。
一旦有任务入队，notify_one 唤醒一个线程。
取出任务并解锁，然后执行任务。

3. 实现代码示例

以下是简化但完整的线程池实现：

#include <iostream>
#include <vector>
#include <queue>
#include <thread>
#include <functional>
#include <mutex>
#include <condition_variable>
#include <future>

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(); // 执行任务
                }
            });
        }
    }

    template<class F>
    auto enqueue(F&& f) -> std::future<decltype(f())> {
        using ReturnType = decltype(f());
        auto task = std::make_shared<std::packaged_task<ReturnType()>>(
            std::forward<F>(f)
        );
        std::future<ReturnType> result = task->get_future();

        {
            std::lock_guard<std::mutex> lock(queue_mutex);
            if (stop) throw std::runtime_error("enqueue on stopped ThreadPool");
            tasks.emplace([task]() { (*task)(); });
        }

        condition.notify_one();
        return result;
    }

    ~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;
};

登录后复制

4. 使用示例

你可以这样使用这个线程池：

```cpp int main() { ThreadPool pool(4); // 创建4个线程的线程池

std::vector<std::future<int>> results;
for (int i = 0; i < 8; ++i) {
    results.emplace_back(
        pool.enqueue([i] {
            std::cout << "任务 " << i << " 正在运行，线程ID: " << std::this_thread::get_id() << std::endl;
            return i * i;
        })
    );
}

// 获取结果
for (auto&& result : results) {
    std::cout << "结果: " << result.get() << std::endl;
}

return 0;

登录后复制

}


<p>该实现支持异步提交任务并获取返回值（通过 std::future），适用于大多数常见场景。</p>

<p>基本上就这些。核心在于用队列管理任务，用 condition_variable 实现线程阻塞与唤醒，注意锁的粒度和异常安全即可。</p>

登录后复制

以上就是C++如何实现线程池_C++ 线程池实现方法的详细内容，更多请关注php中文网其它相关文章！

大家都在看：

如何配置C++的AI推理框架环境 TensorRT加速库安装使用 C++与AI部署：ONNX Runtime集成全解析 C++ 如何计算数组的长度_C++ 数组长度计算的常见方法 c++怎么创建一个多线程程序_c++多线程并发编程入门实例 C++ 如何生成随机数_C++ 随机数生成 rand 与用法