Searched refs:TaskQueue (Results 1 – 6 of 6) sorted by relevance
34 class TaskQueue {42 explicit Task(Callable C, TaskQueue &Parent) in Task()64 TaskQueue *Parent;69 TaskQueue(ThreadPool &Scheduler) : Scheduler(Scheduler) { (void)Scheduler; } in TaskQueue() function72 ~TaskQueue() { in ~TaskQueue()
23 class TaskQueue {25 TaskQueue();26 ~TaskQueue() = default;106 TaskQueue<v8::Task> foreground_tasks_;107 TaskQueue<DelayedTask> foreground_delayed_tasks_;130 TaskQueue<v8::Task> pending_worker_tasks_;
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::TaskQueue553 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()[all …]
124 using TaskQueue = std::vector<Task>; in MultiQueueTaskExecutor() typedef131 std::vector<TaskQueue> taskQueues(numQueues); in MultiQueueTaskExecutor()
66 typedef de::ThreadSafeRingBuffer<Task*> TaskQueue; typedef71 TaskExecutorThread (TaskQueue& tasks) in TaskExecutorThread()91 TaskQueue& m_tasks;107 TaskQueue m_tasks;
320 using TaskQueue = containers::deque<Task>; variable440 GUARDED_BY(mutex) TaskQueue tasks;