/dports/multimedia/libgav1/libgav1-0.17.0/src/utils/ |
H A D | threadpool.h | 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_; 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 D | threadpool.h | 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_; 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 D | threadpool.h | 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_; 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 D | mpmc_blocking_q.h | 35 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 D | mpmc_blocking_q.h | 35 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 D | mpmc_blocking_q.h | 38 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 D | mpmc_blocking_q.h | 35 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 D | TileManager.cc | 43 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 D | request_queue_impl_1q.cpp | 73 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 D | request_queue_impl_1q.hpp | 38 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 D | msg_loop.cc | 28 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 D | worker_pool.cc | 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()
|
H A D | msg_loop.h | 39 std::mutex queue_mutex_;
|
H A D | worker_pool.h | 30 std::mutex queue_mutex_; variable
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/gn/util/ |
H A D | msg_loop.cc | 28 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 D | worker_pool.cc | 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()
|
H A D | msg_loop.h | 39 std::mutex queue_mutex_;
|
H A D | worker_pool.h | 30 std::mutex queue_mutex_; variable
|
/dports/devel/gn/gn-1962/src/util/ |
H A D | msg_loop.cc | 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()
|
H A D | worker_pool.cc | 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()
|
H A D | msg_loop.h | 37 std::mutex queue_mutex_;
|
H A D | worker_pool.h | 29 std::mutex queue_mutex_; variable
|
/dports/net/onioncat/onioncat-0.3.9/src/ |
H A D | ocatroute.c | 46 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 D | forward_iterator_bench.cc | 106 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 D | forward_iterator_bench.cc | 107 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
|