#include #include #include #include #include #include #include #include #include #include #include #include #include using namespace std; class myThreadPool { public: myThreadPool(int cnt) : m_intTotalThreads(cnt) , m_bIsToTerminate(false) { m_vThreads.resize(m_intTotalThreads); } void start() { for (int i = 0; i < m_intTotalThreads; i++) { m_vThreads.at(i) = thread(&myThreadPool::ThreadLoop,this); } } void ThreadLoop() { while (true) { std::function jobFunc; { std::unique_lock lock(queue_mutex); mutex_condition.wait(lock, [this] {return !m_qJobs.empty() || m_bIsToTerminate;}); if (m_bIsToTerminate && m_qJobs.empty()) return; jobFunc = m_qJobs.front(); m_qJobs.pop(); } jobFunc(); } } void addJob(function fn) { { unique_lock um(queue_mutex); m_qJobs.push(fn); } mutex_condition.notify_one(); } bool busy() { bool poolbusy; { std::unique_lock lock(queue_mutex); poolbusy = m_qJobs.empty(); } return poolbusy; } void stop() { { std::unique_lock lock(queue_mutex); m_bIsToTerminate = true; } mutex_condition.notify_all(); for (std::thread& active_thread : m_vThreads) { active_thread.join(); } m_vThreads.clear(); } private: int m_intTotalThreads; vector m_vThreads; queue> m_qJobs; bool m_bIsToTerminate; mutex queue_mutex; condition_variable mutex_condition; }; void func() { auto myid = this_thread::get_id(); stringstream ss; ss << myid; string mystring = ss.str(); cout << mystring << endl; } int main() { int cntThreads = 5; myThreadPool objThreadPool(cntThreads); objThreadPool.start(); string str; for (int i = 0; i < 20; ++i) { objThreadPool.addJob(func); } objThreadPool.stop(); return 0; }

ThreadPool_Trial