Github开源项目源码阅读（progschjThreadPool）

项目地址：https://github.com/progschj/ThreadPool
项目源码：

1. #ifndef THREAD_POOL_H
2. #define THREAD_POOL_H
3. <h1 id="include-vector">include <vector></h1>
4. <h1 id="include-queue">include <queue></h1>
5. <h1 id="include-memory">include <memory></h1>
6. <h1 id="include-thread">include <thread></h1>
7. <h1 id="include-mutex">include <mutex></h1>
8. <h1 id="include-condition_variable">include <condition_variable></h1>
9. <h1 id="include-future">include <future></h1>
10. <h1 id="include-functional">include <functional></h1>
11. <h1 id="include-stdexcept">include <stdexcept></h1>
12. <p>class ThreadPool {
    
14. public:
    
16. ThreadPool(size_t);
    
18. template<class F, class... Args>
    
20. auto enqueue(F&& f, Args&&... args)
    
22. -> std::future<typename std::result_of<F(Args...)>::type>;
    
24. ~ThreadPool();
    
26. private:
    
28. // need to keep track of threads so we can join them
    
30. std::vector< std::thread > workers;
    
32. // the task queue
    
34. std::queue< std::function<void()> > tasks;</p>
35. [code]// synchronization
36. std::mutex queue_mutex;
37. std::condition_variable condition;
38. bool stop;

复制代码

};

// the constructor just launches some amount of workers
inline ThreadPool::ThreadPool(size_t threads)
:   stop(false)
{
for(size_t i = 0;i