Searched refs:workers_ (Results 1 – 4 of 4) sorted by relevance
238 workers_.push_back(thread); in ThreadPool()244 for (size_t i = 0; i < workers_.size(); i++) { in StartWorkers()245 workers_[i]->Start(); in StartWorkers()254 int num_threads() { return workers_.size();} in num_threads()258 for (size_t i = 0; i < workers_.size(); i++) { in ~ThreadPool()261 for (size_t i = 0; i < workers_.size(); i++) { in ~ThreadPool()262 workers_[i]->Join(); in ~ThreadPool()263 delete workers_[i]; in ~ThreadPool() local267 std::vector<MyThread*> workers_;
20 workers_(workers), in SyncSession()39 std::set_union(workers_.begin(), workers_.end(), in Coalesce()40 session.workers_.begin(), session.workers_.end(), in Coalesce()42 workers_.swap(temp); in Coalesce()
125 const std::vector<ModelSafeWorker*>& workers() const { return workers_; } in workers()155 std::vector<ModelSafeWorker*> workers_; variable
508 workers_.push_back(thread); in ThreadPool()514 for (size_t i = 0; i < workers_.size(); i++) { in StartWorkers()515 workers_[i]->Start(); in StartWorkers()524 int num_threads() { return workers_.size();} in num_threads()528 for (size_t i = 0; i < workers_.size(); i++) { in ~ThreadPool()531 for (size_t i = 0; i < workers_.size(); i++) { in ~ThreadPool()532 workers_[i]->Join(); in ~ThreadPool()533 delete workers_[i]; in ~ThreadPool() local537 std::vector<MyThread*> workers_;