Searched refs:task_queue_lock_ (Results 1 – 2 of 2) sorted by relevance
| /aosp12/art/runtime/ |
| H A D | thread_pool.h | 121 void StartWorkers(Thread* self) REQUIRES(!task_queue_lock_);
124 void StopWorkers(Thread* self) REQUIRES(!task_queue_lock_);
181 Task* TryGetTask(Thread* self) REQUIRES(!task_queue_lock_);
182 Task* TryGetTaskLocked() REQUIRES(task_queue_lock_);
185 bool IsShuttingDown() const REQUIRES(task_queue_lock_) { in IsShuttingDown()
194 Mutex task_queue_lock_; variable
197 volatile bool started_ GUARDED_BY(task_queue_lock_);
198 volatile bool shutting_down_ GUARDED_BY(task_queue_lock_);
201 std::deque<Task*> tasks_ GUARDED_BY(task_queue_lock_);
204 uint64_t start_time_ GUARDED_BY(task_queue_lock_);
[all …]
|
| H A D | thread_pool.cc | 143 MutexLock mu(self, task_queue_lock_); in AddTask()
158 MutexLock mu(self, task_queue_lock_); in RemoveAllTasks()
186 MutexLock mu(self, task_queue_lock_); in CreateThreads()
212 MutexLock mu(self, task_queue_lock_); in DeleteThreads()
226 MutexLock mu(Thread::Current(), task_queue_lock_); in SetMaxActiveWorkers()
237 MutexLock mu(self, task_queue_lock_); in StartWorkers()
245 MutexLock mu(self, task_queue_lock_); in StopWorkers()
250 MutexLock mu(self, task_queue_lock_); in GetTask()
282 MutexLock mu(self, task_queue_lock_); in TryGetTask()
305 MutexLock mu(self, task_queue_lock_); in Wait()
[all …]
|