Searched refs:delayed_incoming_queue (Results 1 – 2 of 2) sorted by relevance
169 std::priority_queue<Task> delayed_incoming_queue; in UnregisterTaskQueue() local170 delayed_incoming_queue.swap(main_thread_only().delayed_incoming_queue); in UnregisterTaskQueue()255 main_thread_only().delayed_incoming_queue.push(std::move(pending_task)); in PushOntoDelayedIncomingQueueFromMainThread()288 main_thread_only().delayed_incoming_queue.push(std::move(pending_task)); in ScheduleDelayedWorkTask()367 !main_thread_only().delayed_incoming_queue.empty() || in IsEmpty()379 task_count += main_thread_only().delayed_incoming_queue.size(); in GetNumberOfPendingTasks()396 if (!main_thread_only().delayed_incoming_queue.empty() && in HasTaskToRunImmediately()397 main_thread_only().delayed_incoming_queue.top().delayed_run_time <= in HasTaskToRunImmediately()410 if (main_thread_only().delayed_incoming_queue.empty() || !IsQueueEnabled()) in GetNextScheduledWakeUpImpl()413 return main_thread_only().delayed_incoming_queue.top().delayed_wake_up(); in GetNextScheduledWakeUpImpl()[all …]
352 std::priority_queue<TaskQueueImpl::Task> delayed_incoming_queue; member