Searched refs:main_thread_only (Results 1 – 7 of 7) sorted by relevance
138 if (main_thread_only().time_domain) in UnregisterTaskQueue()139 main_thread_only().time_domain->UnregisterQueue(this); in UnregisterTaskQueue()144 main_thread_only().on_task_completed_handler = OnTaskCompletedHandler(); in UnregisterTaskQueue()146 main_thread_only().time_domain = nullptr; in UnregisterTaskQueue()149 main_thread_only().sequence_manager = nullptr; in UnregisterTaskQueue()152 main_thread_only().on_next_wake_up_changed_callback = in UnregisterTaskQueue()170 delayed_incoming_queue.swap(main_thread_only().delayed_incoming_queue); in UnregisterTaskQueue()173 std::move(main_thread_only().immediate_work_queue); in UnregisterTaskQueue()175 std::move(main_thread_only().delayed_work_queue); in UnregisterTaskQueue()220 if (!main_thread_only().sequence_manager) in PostDelayedTaskImpl()[all …]
87 main_thread_only().selector.SetTaskQueueSelectorObserver(this); in SequenceManagerImpl()89 RegisterTimeDomain(main_thread_only().real_time_domain.get()); in SequenceManagerImpl()103 for (internal::TaskQueueImpl* queue : main_thread_only().active_queues) { in ~SequenceManagerImpl()104 main_thread_only().selector.RemoveQueue(queue); in ~SequenceManagerImpl()108 main_thread_only().active_queues.clear(); in ~SequenceManagerImpl()109 main_thread_only().queues_to_gracefully_shutdown.clear(); in ~SequenceManagerImpl()113 main_thread_only().selector.SetTaskQueueSelectorObserver(nullptr); in ~SequenceManagerImpl()137 main_thread_only().time_domains.insert(time_domain); in RegisterTimeDomain()142 main_thread_only().time_domains.erase(time_domain); in UnregisterTimeDomain()146 return main_thread_only().real_time_domain.get(); in GetRealTimeDomain()[all …]
37 DCHECK(!main_thread_only().task_source); in SetSequencedTaskSource()38 main_thread_only().task_source = task_source; in SetSequencedTaskSource()44 main_thread_only().batch_size = work_batch_size; in SetWorkBatchSize()63 if (main_thread_only().next_delayed_work == run_time) in SetNextDelayedDoWork()65 main_thread_only().next_delayed_work = run_time; in SetNextDelayedDoWork()89 main_thread_only().thread_task_runner_handle = in SetDefaultTaskRunner()95 main_thread_only().thread_task_runner_handle.reset(); in RestoreDefaultTaskRunner()100 DCHECK_LE(main_thread_only().run_depth, 1); in AddNestingObserver()101 DCHECK(!main_thread_only().nesting_observer); in AddNestingObserver()103 main_thread_only().nesting_observer = observer; in AddNestingObserver()[all …]
233 return main_thread_only().delayed_work_queue.get(); in delayed_work_queue()237 return main_thread_only().delayed_work_queue.get(); in delayed_work_queue()241 return main_thread_only().immediate_work_queue.get(); in immediate_work_queue()245 return main_thread_only().immediate_work_queue.get(); in immediate_work_queue()258 HeapHandle heap_handle() const { return main_thread_only().heap_handle; } in heap_handle()261 main_thread_only().heap_handle = heap_handle; in set_heap_handle()438 MainThreadOnly& main_thread_only() { in main_thread_only() function442 const MainThreadOnly& main_thread_only() const { in main_thread_only() function
323 MainThreadOnly& main_thread_only() { in main_thread_only() function327 const MainThreadOnly& main_thread_only() const { in main_thread_only() function
83 MainThreadOnly& main_thread_only() { in main_thread_only() function
55 return main_thread_only().active_queues.size(); in ActiveQueuesCount()59 return !main_thread_only().selector.AllEnabledWorkQueuesAreEmpty(); in HasImmediateWork()64 for (auto* const queue : main_thread_only().active_queues) in PendingTasksCount()70 return main_thread_only().queues_to_delete.size(); in QueuesToDeleteCount()75 return main_thread_only().queues_to_gracefully_shutdown.size(); in QueuesToShutdownCount()