Searched refs:worker_threads_ (Results 1 – 4 of 4) sorted by relevance
57 worker_threads_.push_back(std::move(wt)); in InitializeWorkers()320 for (int i = 0; i < worker_threads_.size(); i++) { in Start()322 std::async(std::launch::async, &Worker::RunThread, worker_threads_[i].get())); in Start()
320 worker_threads_.clear(); in FreeResources()422 std::vector<std::unique_ptr<Worker>> worker_threads_; variable
224 worker_threads_.clear(); in FreeResources()315 std::vector<std::unique_ptr<WorkerThread>> worker_threads_; variable
60 worker_threads_.push_back(std::move(wt)); in InitializeWorkers()778 for (int i = 0; i < worker_threads_.size(); i++) { in Start()780 std::async(std::launch::async, &WorkerThread::RunThread, worker_threads_[i].get())); in Start()