| 99 | |
| 100 | template<typename T> |
| 101 | bool ThreadPool<T>::execute(Worker<T> &&task, std::future<T> &future) { |
| 102 | { |
| 103 | std::unique_lock<std::mutex> lock(worker_queue_mutex_); |
| 104 | task_status_[task.getIdentifier()] = true; |
| 105 | } |
| 106 | future = std::move(task.getPromise()->get_future()); |
| 107 | worker_queue_.enqueue(std::move(task)); |
| 108 | |
| 109 | task_count_++; |
| 110 | |
| 111 | return true; |
| 112 | } |
| 113 | |
| 114 | template<typename T> |
| 115 | void ThreadPool<T>::manageWorkers() { |
no test coverage detected