Lines Matching refs:TaskQueue
20 TaskQueue<Task>* task_queue;
31 TaskQueue<Task>* pending_worker_tasks = worker_data->task_queue; in PlatformWorkerThread()
52 explicit DelayedTaskScheduler(TaskQueue<Task>* tasks) in DelayedTaskScheduler()
158 TaskQueue<Task>* pending_worker_tasks_;
160 TaskQueue<Task> tasks_;
548 TaskQueue<T>::TaskQueue() in TaskQueue() function in node::TaskQueue
553 void TaskQueue<T>::Push(std::unique_ptr<T> task) { in Push()
561 std::unique_ptr<T> TaskQueue<T>::Pop() { in Pop()
572 std::unique_ptr<T> TaskQueue<T>::BlockingPop() { in BlockingPop()
586 void TaskQueue<T>::NotifyOfCompletion() { in NotifyOfCompletion()
594 void TaskQueue<T>::BlockingDrain() { in BlockingDrain()
602 void TaskQueue<T>::Stop() { in Stop()
609 std::queue<std::unique_ptr<T>> TaskQueue<T>::PopAll() { in PopAll()