Searched refs:delayed_incoming_queue (Results 1 – 7 of 7) 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
358 DelayedIncomingQueue delayed_incoming_queue; in UnregisterTaskQueue() local359 delayed_incoming_queue.swap(&main_thread_only().delayed_incoming_queue); in UnregisterTaskQueue()402 main_thread_only().delayed_incoming_queue.remove(heap_handle); in RemoveCancelableTask()534 main_thread_only().delayed_incoming_queue.push(std::move(pending_task)); in PushOntoDelayedIncomingQueueFromMainThread()571 main_thread_only().delayed_incoming_queue.push(std::move(pending_task)); in ScheduleDelayedWorkTask()629 !main_thread_only().delayed_incoming_queue.empty() || in IsEmpty()641 task_count += main_thread_only().delayed_incoming_queue.size(); in GetNumberOfPendingTasks()658 if (!main_thread_only().delayed_incoming_queue.empty() && in HasTaskToRunImmediatelyOrReadyDelayedTask()659 main_thread_only().delayed_incoming_queue.top().delayed_run_time <= in HasTaskToRunImmediatelyOrReadyDelayedTask()671 if (main_thread_only().delayed_incoming_queue.empty() || !IsQueueEnabled()) in GetNextDesiredWakeUp()[all …]
187 .delayed_incoming_queue.has_pending_high_resolution_tasks(); in has_pending_high_resolution_tasks()423 DelayedIncomingQueue delayed_incoming_queue; member
56 is then pushed on `main_thread_only().delayed_incoming_queue` and possibly
355 std::priority_queue<TaskQueueImpl::Task> delayed_incoming_queue; member