Home
last modified time | relevance | path

Searched refs:queue_mutex_ (Results 1 – 25 of 38) sorted by relevance

12

/dports/multimedia/libgav1/libgav1-0.17.0/src/utils/
H A Dthreadpool.h122 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_; variable
139 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_; variable
150 UnboundedQueue<std::function<void()>> queue_ LIBGAV1_GUARDED_BY(queue_mutex_);
155 bool exit_threads_ LIBGAV1_GUARDED_BY(queue_mutex_) = false;
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/libgav1/src/src/utils/
H A Dthreadpool.h122 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_; variable
139 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_; variable
150 UnboundedQueue<std::function<void()>> queue_ LIBGAV1_GUARDED_BY(queue_mutex_);
155 bool exit_threads_ LIBGAV1_GUARDED_BY(queue_mutex_) = false;
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/libgav1/src/src/utils/
H A Dthreadpool.h122 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_; variable
139 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_; variable
150 UnboundedQueue<std::function<void()>> queue_ LIBGAV1_GUARDED_BY(queue_mutex_);
155 bool exit_threads_ LIBGAV1_GUARDED_BY(queue_mutex_) = false;
/dports/devel/spdlog/spdlog-1.9.2/include/spdlog/details/
H A Dmpmc_blocking_q.h35 std::unique_lock<std::mutex> lock(queue_mutex_); in enqueue()
46 std::unique_lock<std::mutex> lock(queue_mutex_); in enqueue_nowait()
57 std::unique_lock<std::mutex> lock(queue_mutex_); in dequeue_for()
76 std::unique_lock<std::mutex> lock(queue_mutex_); in enqueue()
85 std::unique_lock<std::mutex> lock(queue_mutex_); in enqueue_nowait()
94 std::unique_lock<std::mutex> lock(queue_mutex_); in dequeue_for()
109 std::unique_lock<std::mutex> lock(queue_mutex_); in overrun_counter()
115 std::unique_lock<std::mutex> lock(queue_mutex_); in size()
120 std::mutex queue_mutex_;
/dports/deskutils/flameshot/flameshot-0.10.2/external/spdlog/include/spdlog/details/
H A Dmpmc_blocking_q.h35 std::unique_lock<std::mutex> lock(queue_mutex_); in enqueue()
46 std::unique_lock<std::mutex> lock(queue_mutex_); in enqueue_nowait()
57 std::unique_lock<std::mutex> lock(queue_mutex_); in dequeue_for()
76 std::unique_lock<std::mutex> lock(queue_mutex_); in enqueue()
85 std::unique_lock<std::mutex> lock(queue_mutex_); in enqueue_nowait()
94 std::unique_lock<std::mutex> lock(queue_mutex_); in dequeue_for()
109 std::unique_lock<std::mutex> lock(queue_mutex_); in overrun_counter()
115 std::unique_lock<std::mutex> lock(queue_mutex_); in size()
120 std::mutex queue_mutex_;
/dports/games/nxengine/nxengine-evo-2.6.5-1/deps/spdlog/details/
H A Dmpmc_blocking_q.h38 std::unique_lock<std::mutex> lock(queue_mutex_); in enqueue()
49 std::unique_lock<std::mutex> lock(queue_mutex_); in enqueue_nowait()
60 std::unique_lock<std::mutex> lock(queue_mutex_); in dequeue_for()
78 std::unique_lock<std::mutex> lock(queue_mutex_); in enqueue()
87 std::unique_lock<std::mutex> lock(queue_mutex_); in enqueue_nowait()
96 std::unique_lock<std::mutex> lock(queue_mutex_); in dequeue_for()
110 std::unique_lock<std::mutex> lock(queue_mutex_); in overrun_counter()
115 std::mutex queue_mutex_;
/dports/devel/taskflow/taskflow-3.2.0/3rd-party/spdlog/details/
H A Dmpmc_blocking_q.h35 std::unique_lock<std::mutex> lock(queue_mutex_); in enqueue()
46 std::unique_lock<std::mutex> lock(queue_mutex_); in enqueue_nowait()
57 std::unique_lock<std::mutex> lock(queue_mutex_); in dequeue_for()
76 std::unique_lock<std::mutex> lock(queue_mutex_); in enqueue()
85 std::unique_lock<std::mutex> lock(queue_mutex_); in enqueue_nowait()
94 std::unique_lock<std::mutex> lock(queue_mutex_); in dequeue_for()
109 std::unique_lock<std::mutex> lock(queue_mutex_); in overrun_counter()
114 std::mutex queue_mutex_;
/dports/graphics/glosm/glosm-glosm-0.0.2/libglosm-client/src/
H A DTileManager.cc43 if ((errn = pthread_mutex_init(&queue_mutex_, 0)) != 0) { in TileManager()
50 pthread_mutex_destroy(&queue_mutex_); in TileManager()
56 pthread_mutex_destroy(&queue_mutex_); in TileManager()
79 pthread_mutex_destroy(&queue_mutex_); in ~TileManager()
328 pthread_mutex_lock(&queue_mutex_); in LoadingThreadFunc()
332 pthread_cond_wait(&queue_cond_, &queue_mutex_); in LoadingThreadFunc()
343 pthread_mutex_unlock(&queue_mutex_); in LoadingThreadFunc()
365 pthread_mutex_lock(&queue_mutex_); in LoadingThreadFunc()
368 pthread_mutex_unlock(&queue_mutex_); in LoadingThreadFunc()
392 pthread_mutex_lock(&queue_mutex_); in Load()
[all …]
/dports/misc/thrill/thrill-12c5b59bca66df93b66628b3829027bd0f110dd9/extlib/foxxll/foxxll/io/
H A Drequest_queue_impl_1q.cpp73 std::unique_lock<std::mutex> lock(queue_mutex_); in add_request()
84 std::unique_lock<std::mutex> lock(queue_mutex_); in add_request()
101 std::unique_lock<std::mutex> lock(queue_mutex_); in cancel_request()
131 std::unique_lock<std::mutex> lock(pthis->queue_mutex_); in worker()
H A Drequest_queue_impl_1q.hpp38 std::mutex queue_mutex_; member in foxxll::request_queue_impl_1q
/dports/www/chromium-legacy/chromium-88.0.4324.182/tools/gn/src/util/
H A Dmsg_loop.cc28 std::unique_lock<std::mutex> queue_lock(queue_mutex_); in Run()
50 std::unique_lock<std::mutex> queue_lock(queue_mutex_); in PostTask()
61 std::unique_lock<std::mutex> queue_lock(queue_mutex_); in RunUntilIdleForTesting()
H A Dworker_pool.cc109 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()
H A Dmsg_loop.h39 std::mutex queue_mutex_;
H A Dworker_pool.h30 std::mutex queue_mutex_; variable
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/gn/util/
H A Dmsg_loop.cc28 std::unique_lock<std::mutex> queue_lock(queue_mutex_); in Run()
51 std::unique_lock<std::mutex> queue_lock(queue_mutex_); in PostTask()
62 std::unique_lock<std::mutex> queue_lock(queue_mutex_); in RunUntilIdleForTesting()
H A Dworker_pool.cc109 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()
H A Dmsg_loop.h39 std::mutex queue_mutex_;
H A Dworker_pool.h30 std::mutex queue_mutex_; variable
/dports/devel/gn/gn-1962/src/util/
H A Dmsg_loop.cc34 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()
H A Dworker_pool.cc109 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()
H A Dmsg_loop.h37 std::mutex queue_mutex_;
H A Dworker_pool.h29 std::mutex queue_mutex_; variable
/dports/net/onioncat/onioncat-0.3.9/src/
H A Docatroute.c46 static pthread_mutex_t queue_mutex_ = PTHREAD_MUTEX_INITIALIZER; variable
109 pthread_mutex_lock(&queue_mutex_); in queue_packet()
114 pthread_mutex_unlock(&queue_mutex_); in queue_packet()
128 pthread_mutex_lock(&queue_mutex_); in packet_dequeuer()
144 rc = pthread_cond_timedwait(&queue_cond_, &queue_mutex_, &ts); in packet_dequeuer()
149 rc = pthread_cond_wait(&queue_cond_, &queue_mutex_); in packet_dequeuer()
173 pthread_mutex_unlock(&queue_mutex_); in packet_dequeuer()
/dports/textproc/sonic/sonic-1.3.0/cargo-crates/librocksdb-sys-6.7.4/rocksdb/db/
H A Dforward_iterator_bench.cc106 std::lock_guard<std::mutex> guard(queue_mutex_); in run()
174 std::lock_guard<std::mutex> guard(queue_mutex_); in onWrite()
195 std::mutex queue_mutex_; member
/dports/databases/percona57-client/percona-server-5.7.36-39/storage/rocksdb/rocksdb/db/
H A Dforward_iterator_bench.cc107 std::lock_guard<std::mutex> guard(queue_mutex_); in run()
176 std::lock_guard<std::mutex> guard(queue_mutex_); in onWrite()
197 std::mutex queue_mutex_; member

12