Searched refs:queue_mutex_ (Results 1 – 1 of 1) sorted by relevance
122 void LockMutex() { queue_mutex_.lock(); } in LockMutex()123 void UnlockMutex() { queue_mutex_.unlock(); } in UnlockMutex()126 std::unique_lock<std::mutex> queue_lock(queue_mutex_, std::adopt_lock); in Wait()135 std::mutex queue_mutex_; variable139 void LockMutex() ABSL_EXCLUSIVE_LOCK_FUNCTION() { queue_mutex_.Lock(); } in LockMutex()140 void UnlockMutex() ABSL_UNLOCK_FUNCTION() { queue_mutex_.Unlock(); } in UnlockMutex()141 void Wait() { condition_.Wait(&queue_mutex_); } in Wait()146 absl::Mutex queue_mutex_; variable150 UnboundedQueue<std::function<void()>> queue_ LIBGAV1_GUARDED_BY(queue_mutex_);155 bool exit_threads_ LIBGAV1_GUARDED_BY(queue_mutex_) = false;