Searched defs:WorkerState (Results 1 – 7 of 7) sorted by relevance
611 struct WorkerState { struct in tensorflow::data::experimental::ParallelInterleaveDatasetOp::Dataset::Iterator613 std::vector<Tensor> input;615 std::deque<OutputElem> outputs;620 bool is_producing = false;627 condition_variable cond_var;629 inline bool MayHaveElements() const { in MayHaveElements()634 void SetInputs(const Status& s, std::vector<Tensor> input_arguments) { in SetInputs()
111 struct WorkerState { struct in tensorflow::__anonde36c3c90111::WorkerFreeListCache112 WorkerInterface* worker;
190 class WorkerState(str, Enum): class234 def is_running(state: "WorkerState") -> bool:
963 pub(crate) struct WorkerState<T, U> { struct964 pub(crate) queue_task: TaskHandle<U>,965 pub(crate) queue: T,
151 def monres(state: WorkerState):
999 enum class WorkerState { in <lambda>() class in kotlinx.coroutines.scheduling.CoroutineScheduler
927 enum WorkerState { enum