| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| D | task_manager.cpp | 74 std::lock_guard<std::recursive_mutex> lock(workersMutex_); in ~TaskManager() local
82 std::unique_lock<std::shared_mutex> lock(tasksMutex_); in ~TaskManager() local
94 std::lock_guard<std::recursive_mutex> lock(workersMutex_); in CountTraceForWorker() local
109 std::lock_guard<std::recursive_mutex> lock(workersMutex_); in GetThreadInfos() local
124 std::lock_guard<std::mutex> lock(worker->currentTaskIdMutex_); in GetThreadInfos() local
148 std::unique_lock<std::shared_mutex> lock(tasksMutex_); in GetTaskInfos() local
156 std::unique_lock<std::shared_mutex> lock(task->taskMutex_); in GetTaskInfos() local
211 std::lock_guard<std::recursive_mutex> lock(workersMutex_); in CheckForBlockedWorkers() local
293 std::lock_guard<std::recursive_mutex> lock(workersMutex_); in GetIdleWorkers() local
361 std::lock_guard<std::recursive_mutex> lock(workersMutex_); in GetIdleWorkers() local
[all …]
|
| D | worker.cpp | 127 std::lock_guard<std::mutex> lock(debuggerMutex_); in DebuggerOnPostTask() local
351 std::lock_guard<std::mutex> lock(worker->currentTaskIdMutex_); in NotifyHandleTaskResult() local
410 std::lock_guard<std::mutex> lock(currentTaskIdMutex_); in StoreTaskId() local
|
| D | task_group.cpp | 134 std::unique_lock<std::shared_mutex> lock(taskGroupMutex_); in NotifyGroupTask() local
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| D | ylong_tokio_rwlock.rs | 52 let lock = Arc::new(RwLock::new(())); in tokio_rwlock_read() localVariable
56 let lock = lock.clone(); in tokio_rwlock_read() localVariable
77 let lock = Arc::new(YlongRwlock::new(())); in ylong_rwlock_read() localVariable
81 let lock = lock.clone(); in ylong_rwlock_read() localVariable
101 let lock = Arc::new(RwLock::new(())); in tokio_rwlock_write() localVariable
105 let lock = lock.clone(); in tokio_rwlock_write() localVariable
126 let lock = Arc::new(YlongRwlock::new(())); in ylong_rwlock_write() localVariable
130 let lock = lock.clone(); in ylong_rwlock_write() localVariable
151 let lock = Arc::new(RwLock::new(())); in tokio_rwlock_write_read() localVariable
183 let lock = Arc::new(YlongRwlock::new(())); in ylong_rwlock_write_read() localVariable
|
| D | ylong_tokio_mutex.rs | 41 let mut lock = mutex1.lock().await; localVariable
69 let mut lock = mutex1.lock().await; localVariable
|
| /commonlibrary/c_utils/base/src/ |
| D | observer.cpp | 28 lock_guard<mutex> lock(mutex_); in AddObserver() local
38 lock_guard<mutex> lock(mutex_); in RemoveObserver() local
44 lock_guard<mutex> lock(mutex_); in RemoveAllObservers() local
55 lock_guard<mutex> lock(mutex_); in GetObserversCount() local
68 lock_guard<mutex> lock(mutex_); in NotifyObservers() local
|
| D | thread_pool.cpp | 64 std::unique_lock<std::mutex> lock(mutex_); in Stop() local
79 std::unique_lock<std::mutex> lock(mutex_); in AddTask() local
91 std::unique_lock<std::mutex> lock(mutex_); in GetCurTaskNum() local
98 std::unique_lock<std::mutex> lock(mutex_); in ScheduleTask() local
|
| D | io_event_reactor.cpp | 92 std::lock_guard<std::mutex> lock(mutex_); in AddHandler() local
151 std::lock_guard<std::mutex> lock(mutex_); in RemoveHandler() local
193 std::lock_guard<std::mutex> lock(mutex_); in FindHandler() local
237 std::lock_guard<std::mutex> lock(mutex_); in HandleEvents() local
286 std::lock_guard<std::mutex> lock(mutex_); in Run() local
334 std::lock_guard<std::mutex> lock(mutex_); in CleanUp() local
353 std::lock_guard<std::mutex> lock(mutex_); in Clean() local
|
| D | event_reactor.cpp | 65 std::lock_guard<std::recursive_mutex> lock(mutex_); in CleanUp() local
97 std::lock_guard<std::recursive_mutex> lock(mutex_); in ScheduleTimer() local
114 std::lock_guard<std::recursive_mutex> lock(mutex_); in CancelTimer() local
|
| D | timer.cpp | 59 std::lock_guard<std::mutex> lock(mutex_); in Shutdown() local
84 std::lock_guard<std::mutex> lock(mutex_); in Register() local
117 std::lock_guard<std::mutex> lock(mutex_); in Unregister() local
183 std::lock_guard<std::mutex> lock(mutex_); in OnTimer() local
242 std::lock_guard<std::mutex> lock(mutex_); in EraseUnusedTimerId() local
|
| D | event_demultiplexer.cpp | 71 std::lock_guard<std::recursive_mutex> lock(mutex_); in UpdateEventHandler() local
122 std::lock_guard<std::recursive_mutex> lock(mutex_); in Polling() local
|
| D | refbase.cpp | 136 std::lock_guard<std::mutex> lock(trackerMutex); in PrintRefs() local
144 std::lock_guard<std::mutex> lock(trackerMutex); in GetNewTrace() local
152 std::lock_guard<std::mutex> lock(trackerMutex); in PrintTracker() local
166 std::lock_guard<std::mutex> lock(trackerMutex); in EnableTracker() local
|
| /commonlibrary/ets_utils/js_concurrent_module/worker/ |
| D | message_queue.cpp | 63 std::unique_lock<std::mutex> lock(queueLock_); in Push() local
69 std::unique_lock<std::mutex> lock(queueLock_); in Pop() local
75 std::unique_lock<std::mutex> lock(queueLock_); in Front() local
81 std::unique_lock<std::mutex> lock(queueLock_); in IsEmpty() local
87 std::unique_lock<std::mutex> lock(queueLock_); in Clear() local
|
| D | worker.cpp | 91 std::lock_guard<std::mutex> lock(g_limitedworkersMutex); in InitPort() local
98 std::lock_guard<std::mutex> lock(g_workersMutex); in InitPort() local
212 std::lock_guard<std::mutex> lock(g_limitedworkersMutex); in Constructor() local
231 std::lock_guard<std::mutex> lock(g_workersMutex); in Constructor() local
270 std::lock_guard<std::recursive_mutex> lock(worker->liveStatusLock_); in Constructor() local
863 std::lock_guard<std::recursive_mutex> lock(worker->liveStatusLock_); in GlobalCall() local
874 std::unique_lock lock(worker->globalCallMutex_); in GlobalCall() local
1196 std::lock_guard<std::recursive_mutex> lock(worker->liveStatusLock_); in ExecuteInThread() local
1250 std::lock_guard<std::recursive_mutex> lock(worker->liveStatusLock_); in ExecuteInThread() local
1264 std::lock_guard<std::recursive_mutex> lock(liveStatusLock_); in PrepareForWorkerInstance() local
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| D | rwlock.rs | 361 let lock = RwLock::new(Test { flag: true, num: 1 }); in ut_rwlock_new_01() localVariable
378 let lock = RwLock::new(100); in ut_rwlock_read_01() localVariable
394 let lock = Arc::new(RwLock::new(100)); in ut_rwlock_read_02() localVariable
416 let lock = RwLock::new(100); in ut_rwlock_try_read_01() localVariable
431 let lock = Arc::new(RwLock::new(100)); in ut_rwlock_try_read_02() localVariable
451 let lock = Arc::new(RwLock::new(100)); in ut_rwlock_write_01() localVariable
472 let lock = Arc::new(RwLock::new(100)); in ut_rwlock_write_test_02() localVariable
503 let lock = RwLock::new(100); in ut_rwlock_try_write_01() localVariable
516 let lock = Arc::new(RwLock::new(100)); in ut_rwlock_try_write_02() localVariable
535 let lock = RwLock::new(10); in ut_rwlock_into_inner_01() localVariable
|
| D | mutex.rs | 95 pub async fn lock(&self) -> MutexGuard<'_, T> { in lock() method
202 let lock = Mutex::new(10); in ut_mutex_new_01() localVariable
217 let mut lock = mutex.lock().await; in ut_mutex_lock_01() localVariable
233 let mut lock = mutex.try_lock().unwrap(); in ut_mutex_try_lock_01() localVariable
282 let lock = mutex.lock().await; in ut_mutex_unlock_01() localVariable
|
| D | wake_list.rs | 95 pub fn lock(&self) -> Lock<'_> { in lock() method
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| D | driver.rs | 54 let mut lock = self.wheel.lock().unwrap(); in timer_register() localVariable
59 let mut lock = self.wheel.lock().unwrap(); in timer_cancel() localVariable
76 let mut lock = self.wheel.lock().unwrap(); in run() localVariable
|
| /commonlibrary/ets_utils/js_sys_module/timer/ |
| D | timer.cpp | 94 std::lock_guard<std::mutex> lock(timeLock); in ClearTimer() local
157 std::lock_guard<std::mutex> lock(timeLock); in TimerCallback() local
216 std::lock_guard<std::mutex> lock(timeLock); in SetTimeoutInner() local
245 std::lock_guard<std::mutex> lock(timeLock); in ClearEnvironmentTimer() local
260 std::lock_guard<std::mutex> lock(timeLock); in HasTimer() local
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/ |
| D | ylong_sync_mutex_perf.rs | 27 let mut lock = mutex.lock().await; in main() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| D | mutex.rs | 46 let mut lock = mutex1.lock().await; in sdv_mutex_lock_hold_longtime() localVariable
|
| /commonlibrary/c_utils/base/test/unittest/common/ |
| D | utils_thread_pool_test.cpp | 109 std::lock_guard<std::mutex> lock(g_mutex); in TestFuncAddOneTime() local
115 std::lock_guard<std::mutex> lock(g_mutex); in TestFuncSubOneTime() local
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| D | current_thread.rs | 137 let mut lock = self.mutex.lock().unwrap(); in park_on_condvar() localVariable
171 let mut lock = self.mutex.lock().unwrap(); in unpark() localVariable
184 let mut lock = self.mutex.lock().unwrap(); in unpark() localVariable
|
| /commonlibrary/memory_utils/libpurgeablemem/cpp/src/ |
| D | purgeable_mem_base.cpp | 170 std::lock_guard<std::mutex> lock(dataLock_); in BeginReadWithDataLock() local
|
| /commonlibrary/c_utils/base/test/benchmarktest/thread_pool_benchmark_test/ |
| D | thread_pool_benchmark_test.cpp | 145 std::lock_guard<std::mutex> lock(g_mutex); in TestFuncAddOneTime() local
152 std::lock_guard<std::mutex> lock(g_mutex); in TestFuncSubOneTime() local
|