线程池并行 实例代码 VC

以下是一个简单的线程池实现的示例代码，使用VC编译器：

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

class ThreadPool {
public:
    ThreadPool(int threadCount) : stop(false) {
        for (int i = 0; i < threadCount; ++i) {
            threads.emplace_back(
                [this] {
                    for (;;) {
                        std::function<void()> task;
                        {
                            std::unique_lock<std::mutex> lock(this->queueMutex);
                            this->condition.wait(lock,
                                [this] { return this->stop || !this->tasks.empty(); });
                            if (this->stop && this->tasks.empty()) {
                                return;
                            }
                            task = std::move(this->tasks.front());
                            this->tasks.pop();
                        }
                        task();
                    }
                }
            );
        }
    }

    template<class F, class... Args>
    void enqueue(F&& f, Args&&... args) {
        {
            std::unique_lock<std::mutex> lock(queueMutex);
            tasks.emplace(std::bind(std::forward<F>(f), std::forward<Args>(args)...));
        }
        condition.notify_one();
    }

    ~ThreadPool() {
        {
            std::unique_lock<std::mutex> lock(queueMutex);
            stop = true;
        }
        condition.notify_all();
        for (std::thread& thread : threads) {
            thread.join();
        }
    }

private:
    std::vector<std::thread> threads;
    std::queue<std::function<void()>> tasks;
    std::mutex queueMutex;
    std::condition_variable condition;
    bool stop;
};

void print(const std::string& str) {
    std::cout << str << std::endl;
}

int main() {
    ThreadPool pool(4);
    for(int i=0; i<20; i++) {
        pool.enqueue(print, "Hello from thread " + std::to_string(i));
    }
    return 0;
}

在上面的代码中，我们实现了一个ThreadPool类，其构造函数接受一个整数参数threadCount，表示线程池的大小。enqueue()函数用于将一个任务添加到线程池中，该函数使用std::bind()来将函数f和其参数args绑定到一个std::function对象中，并将该对象添加到任务队列tasks中。线程池中的每个线程都会不断地从任务队列中取出任务执行，如果任务队列为空，线程会等待condition变量被通知。当线程池析构时，我们需要将stop标记为true，唤醒所有等待condition变量的线程并等待它们执行完毕。