Searched refs:ready_tasks_ (Results 1 – 2 of 2) sorted by relevance
191 ready_tasks_.push(task); in WorkerJoin()203 task_cond_var_.wait(lock, [this] { return !ready_tasks_.empty(); }); in WorkerLoop()204 task = ready_tasks_.front(); in WorkerLoop()205 ready_tasks_.pop(); in WorkerLoop()278 while (!ready_tasks_.empty()) { in OnException()279 (void)done_tasks.emplace_back(ready_tasks_.front()); in OnException()280 ready_tasks_.pop(); in OnException()298 ready_tasks_.push(task); in OnRunGraphFinished()318 ready_tasks_.push(task); in RunTask()
191 std::queue<std::shared_ptr<Task>> ready_tasks_; variable