Home
last modified time | relevance | path

Searched refs:task_queue_lock_ (Results 1 – 2 of 2) sorted by relevance

/art/runtime/
Dthread_pool.h121 void StartWorkers(Thread* self) REQUIRES(!task_queue_lock_);
124 void StopWorkers(Thread* self) REQUIRES(!task_queue_lock_);
127 bool HasStarted(Thread* self) REQUIRES(!task_queue_lock_);
131 void AddTask(Thread* self, Task* task) REQUIRES(!task_queue_lock_);
134 void RemoveAllTasks(Thread* self) REQUIRES(!task_queue_lock_);
156 void Wait(Thread* self, bool do_work, bool may_hold_locks) REQUIRES(!task_queue_lock_);
158 size_t GetTaskCount(Thread* self) REQUIRES(!task_queue_lock_);
167 void SetMaxActiveWorkers(size_t threads) REQUIRES(!task_queue_lock_);
181 virtual Task* GetTask(Thread* self) REQUIRES(!task_queue_lock_);
184 Task* TryGetTask(Thread* self) REQUIRES(!task_queue_lock_);
[all …]
Dthread_pool.cc150 MutexLock mu(self, task_queue_lock_); in AddTask()
165 MutexLock mu(self, task_queue_lock_); in RemoveAllTasks()
174 task_queue_lock_("task queue lock", kGenericBottomLock), in ThreadPool()
175 task_queue_condition_("task queue condition", task_queue_lock_), in ThreadPool()
176 completion_condition_("task completion condition", task_queue_lock_), in ThreadPool()
193 MutexLock mu(self, task_queue_lock_); in CreateThreads()
219 MutexLock mu(self, task_queue_lock_); in DeleteThreads()
233 MutexLock mu(Thread::Current(), task_queue_lock_); in SetMaxActiveWorkers()
244 MutexLock mu(self, task_queue_lock_); in StartWorkers()
252 MutexLock mu(self, task_queue_lock_); in StopWorkers()
[all …]