Lines Matching refs:task_queue_lock_

118   void StartWorkers(Thread* self) REQUIRES(!task_queue_lock_);
121   void StopWorkers(Thread* self) REQUIRES(!task_queue_lock_);
125   void AddTask(Thread* self, Task* task) REQUIRES(!task_queue_lock_);
128   void RemoveAllTasks(Thread* self) REQUIRES(!task_queue_lock_);
150   void Wait(Thread* self, bool do_work, bool may_hold_locks) REQUIRES(!task_queue_lock_);
152   size_t GetTaskCount(Thread* self) REQUIRES(!task_queue_lock_);
161   void SetMaxActiveWorkers(size_t threads) REQUIRES(!task_queue_lock_);
171   virtual Task* GetTask(Thread* self) REQUIRES(!task_queue_lock_);
174   Task* TryGetTask(Thread* self) REQUIRES(!task_queue_lock_);
175   Task* TryGetTaskLocked() REQUIRES(task_queue_lock_);
178   bool IsShuttingDown() const REQUIRES(task_queue_lock_) {  in IsShuttingDown()
182   bool HasOutstandingTasks() const REQUIRES(task_queue_lock_) {  in HasOutstandingTasks()
187   Mutex task_queue_lock_;  variable
188   ConditionVariable task_queue_condition_ GUARDED_BY(task_queue_lock_);
189   ConditionVariable completion_condition_ GUARDED_BY(task_queue_lock_);
190   volatile bool started_ GUARDED_BY(task_queue_lock_);
191   volatile bool shutting_down_ GUARDED_BY(task_queue_lock_);
193   volatile size_t waiting_count_ GUARDED_BY(task_queue_lock_);
194   std::deque<Task*> tasks_ GUARDED_BY(task_queue_lock_);
197   uint64_t start_time_ GUARDED_BY(task_queue_lock_);
200   size_t max_active_workers_ GUARDED_BY(task_queue_lock_);