Searched refs:task_queue_lock_ (Results 1 – 2 of 2) sorted by relevance
/art/runtime/ |
D | thread_pool.h | 121 void StartWorkers(Thread* self) REQUIRES(!task_queue_lock_); 124 void StopWorkers(Thread* self) REQUIRES(!task_queue_lock_); 128 void AddTask(Thread* self, Task* task) REQUIRES(!task_queue_lock_); 131 void RemoveAllTasks(Thread* self) REQUIRES(!task_queue_lock_); 153 void Wait(Thread* self, bool do_work, bool may_hold_locks) REQUIRES(!task_queue_lock_); 155 size_t GetTaskCount(Thread* self) REQUIRES(!task_queue_lock_); 164 void SetMaxActiveWorkers(size_t threads) REQUIRES(!task_queue_lock_); 178 virtual Task* GetTask(Thread* self) REQUIRES(!task_queue_lock_); 181 Task* TryGetTask(Thread* self) REQUIRES(!task_queue_lock_); 182 Task* TryGetTaskLocked() REQUIRES(task_queue_lock_); [all …]
|
D | thread_pool.cc | 143 MutexLock mu(self, task_queue_lock_); in AddTask() 158 MutexLock mu(self, task_queue_lock_); in RemoveAllTasks() 167 task_queue_lock_("task queue lock", kGenericBottomLock), in ThreadPool() 168 task_queue_condition_("task queue condition", task_queue_lock_), in ThreadPool() 169 completion_condition_("task completion condition", task_queue_lock_), in ThreadPool() 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() [all …]
|