\u8fd9\u662f\u4e00\u4e2a\u7b80\u5355\u7684\u7ebf\u7a0b\u6c60\uff0c\u7528C++\u6807\u51c6\u5b9e\u73b0<\/p>\n
#include <thread>\n#include <vector>\n#include <queue>\n#include <mutex>\n#include <condition_variable>\n#include <future>\n#include <functional>\n#include <stdexcept>\n\nclass ThreadPool {\npublic:\n ThreadPool(size_t numThreads);\n ~ThreadPool();\n\n template<typename F, typename... Args>\n auto enqueue(F&& f, Args&&... args) -> std::future<decltype(f(args...))>;\n\nprivate:\n std::vector<std::thread> threads;\n std::queue<std::function<void()>> tasks;\n\n std::mutex queueMutex;\n std::condition_variable condition;\n bool stop{false};\n};\n\n\/\/ \u7ebf\u7a0b\u8fd0\u884c\u51fd\u6570\nvoid ThreadPool::workerThread() {\n while (true) {\n std::function<void()> task;\n\n {\n std::unique_lock<std::mutex> lock(queueMutex);\n condition.wait(lock, [this] { return stop || !tasks.empty(); });\n if (stop && tasks.empty())\n return;\n task = std::move(tasks.front());\n tasks.pop();\n }\n\n task();\n }\n}\n\n\/\/ \u63d0\u4ea4\u4efb\u52a1\ntemplate<typename F, typename... Args>\nauto ThreadPool::enqueue(F&& f, Args&&... args) -> std::future<decltype(f(args...))> {\n \/\/ \u5305\u88c5\u4efb\u52a1\n auto task = std::make_shared<std::packaged_task<decltype(f(args...))(Args...)>>(\n std::bind(std::forward<F>(f), std::forward<Args>(args)...)\n );\n\n std::future<decltype(f(args...))> future = task->get_future();\n {\n std::unique_lock<std::mutex> lock(queueMutex);\n\n \/\/ \u6dfb\u52a0\u4efb\u52a1\u5230\u961f\u5217\n tasks.emplace([task]() { (*task)(); });\n }\n condition.notify_one();\n return future;\n}\n\n\/\/ \u7ebf\u7a0b\u6c60\u6784\u9020\u4e0e\u6790\u6784\nThreadPool::ThreadPool(size_t numThreads) {\n \/\/ \u542f\u52a8\u6307\u5b9a\u6570\u91cf\u7684\u7ebf\u7a0b\n for(size_t i = 0; i < numThreads; ++i) {\n threads.emplace_back(\n std::thread(&ThreadPool::workerThread, this)\n ); \n }\n}\n\nThreadPool::~ThreadPool() {\n {\n std::unique_lock<std::mutex> lock(queueMutex);\n stop = true;\n }\n condition.notify_all();\n\n for(std::thread &thread : threads) {\n thread.join(); \n }\n}\n\n<\/code><\/pre>\n","protected":false},"excerpt":{"rendered":"\u8fd9\u662f\u4e00\u4e2a\u7b80\u5355\u7684\u7ebf\u7a0b\u6c60\uff0c\u7528C++\u6807\u51c6\u5b9e\u73b0 #include <thread> #include <vector> #include <queue> #include <mutex> #include <condition_variable> #include <future> #include <functional> #include <stdexcept> class ThreadPool { public: ThreadPool(size_t numThreads); ~ThreadPool(); template<typename F, typename… Args> auto enqueue(F&& f, Args&&… args) -> std::future<decltype(f(args…))>; private: std::vector<std::thread> threads; std::queue<std::function<void()>> tasks; std::mutex queueMutex; std::condition_variable condition; bool stop{false}; }; \/\/ \u7ebf\u7a0b\u8fd0\u884c\u51fd\u6570 void ThreadPool::workerThread() { while (true) { std::function<void()> task; { std::unique_lock<std::mutex> lock(queueMutex); condition.wait(lock, [this] { return stop || !tasks.empty(); }); if (stop && tasks.empty()) return; task = std::move(tasks.front()); tasks.pop(); } task(); } } \/\/ \u63d0\u4ea4\u4efb\u52a1 template<typename F, typename… Args> auto ThreadPool::enqueue(F&& f, Args&&… args) -> std::future<decltype(f(args…))> { \/\/ \u5305\u88c5\u4efb\u52a1 auto task = std::make_shared<std::packaged_task<decltype(f(args…))(Args…)>>( std::bind(std::forward<F>(f), std::forward<Args>(args)…) ); std::future<decltype(f(args…))> future = task->get_future(); { std::unique_lock<std::mutex> lock(queueMutex); \/\/ \u6dfb\u52a0\u4efb\u52a1\u5230\u961f\u5217 tasks.emplace([task]() { (*task)(); }); } condition.notify_one(); return future; } \/\/ \u7ebf\u7a0b\u6c60\u6784\u9020\u4e0e\u6790\u6784 ThreadPool::ThreadPool(size_t numThreads) { \/\/ \u542f\u52a8\u6307\u5b9a\u6570\u91cf\u7684\u7ebf\u7a0b for(size_t i = 0; i < numThreads; ++i) { threads.emplace_back( std::thread(&ThreadPool::workerThread, this) ); } } ThreadPool::~ThreadPool() { { std::unique_lock<std::mutex> lock(queueMutex); stop = true; } condition.notify_all(); for(std::thread &thread : threads) { thread.join(); } }<\/p>\n","protected":false},"author":1,"featured_media":196,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"inline_featured_image":false,"footnotes":""},"categories":[11,5],"tags":[],"_links":{"self":[{"href":"https:\/\/blog.kishere.cn\/index.php?rest_route=\/wp\/v2\/posts\/345"}],"collection":[{"href":"https:\/\/blog.kishere.cn\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/blog.kishere.cn\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/blog.kishere.cn\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/blog.kishere.cn\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=345"}],"version-history":[{"count":1,"href":"https:\/\/blog.kishere.cn\/index.php?rest_route=\/wp\/v2\/posts\/345\/revisions"}],"predecessor-version":[{"id":346,"href":"https:\/\/blog.kishere.cn\/index.php?rest_route=\/wp\/v2\/posts\/345\/revisions\/346"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/blog.kishere.cn\/index.php?rest_route=\/wp\/v2\/media\/196"}],"wp:attachment":[{"href":"https:\/\/blog.kishere.cn\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=345"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/blog.kishere.cn\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=345"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/blog.kishere.cn\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=345"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}