Searched refs:queue_mutex_ (Results 1 – 7 of 7) sorted by relevance
35 std::lock_guard guard(queue_mutex_); in CreateTaskQueue()49 std::lock_guard guard(queue_mutex_); in Dispose()63 std::lock_guard guard(queue_mutex_); in DisposeTasks()77 std::lock_guard guard(queue_mutex_); in RegisterTask()90 std::lock_guard guard(queue_mutex_); in HasPendingTasks()98 std::lock_guard guard(queue_mutex_); in GetTasksToRunNow()134 std::lock_guard guard(queue_mutex_); in GetNumPendingTasks()154 std::lock_guard guard(queue_mutex_); in AddTaskObserver()161 std::lock_guard guard(queue_mutex_); in RemoveTaskObserver()167 std::lock_guard guard(queue_mutex_); in GetObserversToNotify()[all …]
149 mutable std::mutex queue_mutex_; variable
34 std::unique_lock<std::mutex> queue_lock(queue_mutex_); in Run()56 std::unique_lock<std::mutex> queue_lock(queue_mutex_); in PostTask()67 std::unique_lock<std::mutex> queue_lock(queue_mutex_); in RunUntilIdleForTesting()
109 std::unique_lock<std::mutex> queue_lock(queue_mutex_); in ~WorkerPool()122 std::unique_lock<std::mutex> queue_lock(queue_mutex_); in PostTask()135 std::unique_lock<std::mutex> queue_lock(queue_mutex_); in Worker()
37 std::mutex queue_mutex_;
29 std::mutex queue_mutex_; variable
140 std::scoped_lock lock(queue_mutex_); in Consume()164 std::mutex queue_mutex_; variable169 std::scoped_lock lock(queue_mutex_); in ProducerCommit()179 std::scoped_lock lock(queue_mutex_); in ProducerCommitFront()