c++如何实现一个线程池_c++高性能并发编程模型

答案：C++线程池通过管理线程集合、任务队列和同步机制，减少线程创建开销，支持并发任务调度；使用std::thread、std::queue和std::mutex实现基本结构，通过enqueue提交任务并返回future获取结果；优化手段包括无锁队列、任务窃取、CPU绑定和预分配资源；示例中创建4线程池并行执行8个任务，主线程获取结果输出平方数，适用于多数场景，高性能需求可引入更复杂机制。

在C++中实现一个高性能的线程池，核心目标是高效管理线程资源、减少频繁创建/销毁线程的开销，并支持并发任务调度。以下是构建一个实用且高效的线程池的关键设计与实现方式。

1. 线程池基本结构

一个典型的线程池包含以下几个部分：

• 任务队列：用于存放待执行的任务（通常为函数对象）。
• 线程集合：一组工作线程，从任务队列中取出任务并执行。
• 同步机制：使用互斥锁和条件变量保证线程安全和唤醒等待线程。
• 控制接口：提供提交任务、关闭线程池等操作。

任务通常以 std::function<void></void> 形式存储，支持lambda、函数指针和仿函数。

2. 使用标准库实现简易线程池

以下是一个基于 std::thread、std::queue 和 std::mutex 的简单实现：

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

#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, 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(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;

登录后复制

};

标签： ai c++ 并发编程 无锁 同步机制 标准库 red