Searched refs:current_worker (Results 1 – 2 of 2) sorted by relevance
165 struct current_worker : public worker_interface struct169 current_worker(const this_type&);171 current_worker() in current_worker() function174 virtual ~current_worker() in ~current_worker() argument237 std::shared_ptr<current_worker> wi;241 : wi(std::make_shared<current_worker>()) in current_thread()
313 WorkerState* current_worker = &workers_[current_worker_index]; in GetNextInternal() local314 can_produce_elements |= current_worker->MayHaveElements(); in GetNextInternal()315 if (!current_worker->outputs.empty()) { in GetNextInternal()332 Status s = current_worker->outputs.front().status; in GetNextInternal()336 {{"element_id", current_worker->outputs.front().id}}); in GetNextInternal()338 current_worker->outputs.front().output.swap(*out_tensors); in GetNextInternal()339 current_worker->outputs.pop_front(); in GetNextInternal()340 current_worker->cond_var.notify_one(); in GetNextInternal()342 } else if (current_worker->is_producing && deterministic_) { in GetNextInternal()351 } else if (!current_worker->is_producing) { in GetNextInternal()[all …]