"#include \n#include \n#include \n#include \n#include \n#include \n#include <condition_variable>\n\nclass ThreadPool {\npublic:\n ThreadPool(size_t numThreads) : stop(false) {\n for (size_t i = 0; i < numThreads; ++i) {\n workers.emplace_back([this] {\n while (true) {\n std::function<void()> task;\n {\n std::unique_lockstd::mutex lock(queueMutex);\n condition.wait(lock, [this] { return stop || !tasks.empty(); });\n if (stop && tasks.empty()) {\n return;\n }\n task = std::move(tasks.front());\n tasks.pop();\n }\n task();\n }\n });\n }\n }\n\n ~ThreadPool() {\n {\n std::unique_lockstd::mutex lock(queueMutex);\n stop = true;\n }\n condition.notify_all();\n for (std::thread& worker : workers) {\n worker.join();\n }\n }\n\n template<typename F, typename... Args>\n void enqueue(F&& f, Args&&... args) {\n {\n std::unique_lockstd::mutex lock(queueMutex);\n tasks.emplace([f, args...] { f(args...); });\n }\n condition.notify_one();\n }\n\nprivate:\n std::vectorstd::thread workers;\n std::queue<std::function<void()>> tasks;\n std::mutex queueMutex;\n std::condition_variable condition;\n bool stop;\n};\n\n// 示例使用\nvoid task1(int i) {\n std::cout << "Task 1: " << i << std::endl;\n}\n\nvoid task2(int i, int j) {\n std::cout << "Task 2: " << i << ", " << j << std::endl;\n}\n\nint main() {\n ThreadPool pool(4);\n\n for (int i = 0; i < 8; ++i) {\n pool.enqueue(task1, i);\n }\n \n for (int i = 0; i < 4; ++i) {\n pool.enqueue(task2, i, i+1);\n }\n\n return 0;\n}\n"这是一个简单的 C++ 线程池实现，它使用队列存储任务，每个任务是一个函数对象。线程池的构造函数会创建指定数量的线程，每个线程都会不断地从队列中取出任务并执行。当线程池被销毁时，会通知所有线程停止执行并等待它们完成。线程池还提供了一个 enqueue 方法用于将任务加入队列，并通过条件变量通知线程开始执行任务。在示例中，我们定义了两个任务函数 task1 和 task2，并在主函数中使用 enqueue 方法将任务加入线程池。