Searched refs:active_queues (Results 1 – 3 of 3) sorted by relevance
103 for (internal::TaskQueueImpl* queue : main_thread_only().active_queues) { in ~SequenceManagerImpl()108 main_thread_only().active_queues.clear(); in ~SequenceManagerImpl()159 main_thread_only().active_queues.insert(task_queue.get()); in CreateTaskQueueImpl()224 main_thread_only().active_queues.erase(task_queue.get()); in UnregisterTaskQueueImpl()355 main_thread_only().active_queues.size()); in TakeTask()583 for (auto* const queue : main_thread_only().active_queues) in AsValueWithSelectorResult()630 for (auto* const queue : main_thread_only().active_queues) in SweepCanceledDelayedTasks()652 main_thread_only().active_queues.erase(it->first); in CleanUpQueues()
216 std::set<internal::TaskQueueImpl*> active_queues; member
55 return main_thread_only().active_queues.size(); in ActiveQueuesCount()64 for (auto* const queue : main_thread_only().active_queues) in PendingTasksCount()