Lines Matching refs:task_queue_lock_

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_);
185   bool IsShuttingDown() const REQUIRES(task_queue_lock_) {  in IsShuttingDown()
189   bool HasOutstandingTasks() const REQUIRES(task_queue_lock_) {  in HasOutstandingTasks()
194   Mutex task_queue_lock_;  variable
195   ConditionVariable task_queue_condition_ GUARDED_BY(task_queue_lock_);
196   ConditionVariable completion_condition_ GUARDED_BY(task_queue_lock_);
197   volatile bool started_ GUARDED_BY(task_queue_lock_);
198   volatile bool shutting_down_ GUARDED_BY(task_queue_lock_);
200   volatile size_t waiting_count_ 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_);
207   size_t max_active_workers_ GUARDED_BY(task_queue_lock_);