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 {<br>
13. public:<br>
14. ThreadPool(size_t);<br>
15. template<class F, class... Args><br>
16. auto enqueue(F&& f, Args&&... args)<br>
17. -> std::future<typename std::result_of<F(Args...)>::type>;<br>
18. ~ThreadPool();<br>
19. private:<br>
20. // need to keep track of threads so we can join them<br>
21. std::vector< std::thread > workers;<br>
22. // the task queue<br>
23. std::queue< std::function<void()> > tasks;</p>
24. [code]// synchronization
25. std::mutex queue_mutex;
26. std::condition_variable condition;
27. bool stop;

复制代码

};

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