Searched refs:workers_ (Results 1 – 9 of 9) sorted by relevance
189 workers_(dataset()->num_threads()) {} in Iterator()195 for (auto& worker : workers_) { in ~Iterator()360 workers_[i].SetInputs(s, std::move(args)); in EnsureWorkerThreadsStarted()366 interleave_.push_back(&workers_[i]); in EnsureWorkerThreadsStarted()368 staging_.push_back(&workers_[i]); in EnsureWorkerThreadsStarted()384 workers_[thread_index].cond_var.notify_all(); in WorkerThread()392 while (!cancelled_ && !workers_[thread_index].is_producing) { in WorkerThread()393 workers_[thread_index].cond_var.wait(l); in WorkerThread()396 input.swap(workers_[thread_index].input); in WorkerThread()408 workers_[thread_index].outputs.emplace_back(s); in WorkerThread()[all …]
29 for (auto& p : workers_) { in ~WorkerFreeListCache()40 auto p = workers_.find(target); in CreateWorker()41 if (p != workers_.end()) { in CreateWorker()47 workers_.insert(std::make_pair(target, state)); in CreateWorker()85 std::unordered_map<string, WorkerState> workers_ GUARDED_BY(mu_);
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_;
370 for (auto w : workers_) { in ~WorkersPool()380 assert(workers_count <= workers_.size()); in Execute()384 [this, &n](Task* task) { workers_[n++]->StartWork(task); }); in Execute()401 if (workers_.size() >= workers_count) { in CreateWorkers()404 counter_to_decrement_when_ready_.Reset(workers_count - workers_.size()); in CreateWorkers()405 while (workers_.size() < workers_count) { in CreateWorkers()406 workers_.push_back(new Worker(&counter_to_decrement_when_ready_)); in CreateWorkers()416 std::vector<Worker*> workers_; variable
76 workers_.reserve(worker_count); in init_workers()85 workers_.emplace_back(std::unique_ptr<Worker>(worker)); in init_workers()139 for (auto &worker : workers_) worker->start(); in attach_shell()145 for (auto &worker : workers_) worker->stop(); in detach_shell()397 std::vector<VkCommandPool> cmd_pools(workers_.size() + 1, VK_NULL_HANDLE); in create_command_buffers()398 std::vector<std::vector<VkCommandBuffer>> cmds_vec(workers_.size() + 1, in create_command_buffers()700 for (auto &worker : workers_) worker->update_simulation(); in on_tick()721 for (auto &worker : workers_) worker->draw_objects(framebuffers_[back.image_index]); in on_frame()744 for (auto &worker : workers_) worker->wait_idle(); in on_frame()
122 std::vector<std::unique_ptr<Worker>> workers_; variable
904 : workers_(workers) {} in TensorflowGemmlowpWorkersPool()915 assert(workers_ != nullptr); in Execute()918 workers_->Schedule([this, task]() { in Execute()934 thread::ThreadPool* const workers_;
466 static i::List<Worker*> workers_; variable
411 i::List<Worker*> Shell::workers_; member in v8::Shell1148 if (workers_.length() >= kMaxWorkers) { in WorkerNew()1162 workers_.Add(worker); in WorkerNew()2807 workers_copy.AddAll(workers_); in CleanupWorkers()2808 workers_.Clear(); in CleanupWorkers()