Searched refs:queue_mutex_ (Results 1 – 5 of 5) 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;
136 absl::MutexLock lock(&queue_mutex_); in Unregister()146 absl::Mutex queue_mutex_; variable147 bool cancelled_ ABSL_GUARDED_BY(queue_mutex_) = false;152 queue_mutex_) queue_;
98 absl::MutexLock lock(&queue_mutex_); in ~DeadlineManager()110 absl::MutexLock lock(&queue_mutex_); in AdjustDeadline()161 queue_mutex_.AssertReaderHeld(); in Run()165 absl::MutexLock lock(&queue_mutex_); in Run()171 if (queue_mutex_.AwaitWithDeadline( in Run()
68 std::unique_lock<std::mutex> lock(queue_mutex_); in get_batch()97 std::unique_lock<std::mutex> lock(queue_mutex_); in add_chunk_data()160 std::unique_lock<std::mutex> lock(queue_mutex_); in add_chunk_data()192 std::lock_guard<std::mutex> lock(queue_mutex_); in stop()231 std::mutex queue_mutex_; variable
151 : Snoop(system_clock, queue_buffer_, queue_mutex_, scratch_buffer_) {} in SnoopBuffer()157 sync::VirtualMutex queue_mutex_; variable