Searched refs:FirstComeFirstServedTaskRunner (Results 1 – 3 of 3) sorted by relevance
90 out = std::make_unique<FirstComeFirstServedTaskRunner>(std::move(iterator)); in Create()95 FirstComeFirstServedTaskRunner::FirstComeFirstServedTaskRunner( in FirstComeFirstServedTaskRunner() function in tensorflow::data::FirstComeFirstServedTaskRunner101 FirstComeFirstServedTaskRunner::~FirstComeFirstServedTaskRunner() { Cancel(); } in ~FirstComeFirstServedTaskRunner()103 Status FirstComeFirstServedTaskRunner::GetNext(const GetElementRequest& req, in GetNext()108 Status FirstComeFirstServedTaskRunner::GetNext(GetElementResult& result) { in GetNext()113 Status FirstComeFirstServedTaskRunner::PrefetchFn() { in PrefetchFn()120 void FirstComeFirstServedTaskRunner::RunPrefetchThread() { in RunPrefetchThread()133 FirstComeFirstServedTaskRunner::GetNextFromInputIterator() in GetNextFromInputIterator()151 void FirstComeFirstServedTaskRunner::Cancel() { in Cancel()176 FirstComeFirstServedTaskRunner& fcfs_task_runner) in GetElementResultSequence()
84 class FirstComeFirstServedTaskRunner : public TaskRunner {86 explicit FirstComeFirstServedTaskRunner(88 ~FirstComeFirstServedTaskRunner() override;115 TF_DISALLOW_COPY_AND_ASSIGN(FirstComeFirstServedTaskRunner);146 FirstComeFirstServedTaskRunner& fcfs_task_runner);151 FirstComeFirstServedTaskRunner& fcfs_task_runner_;154 FirstComeFirstServedTaskRunner fcfs_task_runner_;
201 FirstComeFirstServedTaskRunner runner( in TEST()214 FirstComeFirstServedTaskRunner runner( in TEST()226 FirstComeFirstServedTaskRunner runner( in TEST()240 FirstComeFirstServedTaskRunner runner( in TEST()271 FirstComeFirstServedTaskRunner runner( in TEST()289 FirstComeFirstServedTaskRunner runner( in TEST()