| 28 | } |
| 29 | |
| 30 | void ThreadPool::startWorkers() { |
| 31 | started_ = true; |
| 32 | for (int i = 0; i < num_workers_; ++i) |
| 33 | all_workers_.push_back(std::move(std::thread(&RunWorker, this))); |
| 34 | } |
| 35 | |
| 36 | typename ThreadPool::Task ThreadPool::getNextTask() { |
| 37 | std::unique_lock<std::mutex> l(mu_); |
no outgoing calls
no test coverage detected