Searched refs:task_queue_lock_ (Results 1 – 2 of 2) sorted by relevance
| /art/runtime/ |
| D | thread_pool.h | 117 Task* TryGetTaskLocked() EXCLUSIVE_LOCKS_REQUIRED(task_queue_lock_);
120 bool IsShuttingDown() const EXCLUSIVE_LOCKS_REQUIRED(task_queue_lock_) { in IsShuttingDown()
125 Mutex task_queue_lock_; variable
126 ConditionVariable task_queue_condition_ GUARDED_BY(task_queue_lock_);
127 ConditionVariable completion_condition_ GUARDED_BY(task_queue_lock_);
128 volatile bool started_ GUARDED_BY(task_queue_lock_);
129 volatile bool shutting_down_ GUARDED_BY(task_queue_lock_);
131 volatile size_t waiting_count_ GUARDED_BY(task_queue_lock_);
132 std::deque<Task*> tasks_ GUARDED_BY(task_queue_lock_);
136 uint64_t start_time_ GUARDED_BY(task_queue_lock_);
[all …]
|
| D | thread_pool.cc | 70 MutexLock mu(self, task_queue_lock_); in AddTask()
80 task_queue_lock_("task queue lock"), in ThreadPool()
81 task_queue_condition_("task queue condition", task_queue_lock_), in ThreadPool()
82 completion_condition_("task completion condition", task_queue_lock_), in ThreadPool()
102 MutexLock mu(Thread::Current(), task_queue_lock_); in SetMaxActiveWorkers()
110 MutexLock mu(self, task_queue_lock_); in ~ThreadPool()
122 MutexLock mu(self, task_queue_lock_); in StartWorkers()
130 MutexLock mu(self, task_queue_lock_); in StopWorkers()
135 MutexLock mu(self, task_queue_lock_); in GetTask()
167 MutexLock mu(self, task_queue_lock_); in TryGetTask()
[all …]
|