lock (definition) in projects: commonlibrary

Project(s)

Full Search
Definition
Symbol
File Path
History
Type

Searched defs:lock (Results 1 – 25 of 26) sorted by relevance

/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/ets_utils/js_concurrent_module/taskpool/
D	task_manager.cpp	84 std::lock_guard<std::recursive_mutex> lock(workersMutex_); in ~TaskManager() local 92 std::unique_lock<std::shared_mutex> lock(taskInfosMutex_); in ~TaskManager() local 105 std::lock_guard<std::recursive_mutex> lock(workersMutex_); in GetThreadInfos() local 120 std::lock_guard<std::mutex> lock(worker->currentTaskIdMutex_); in GetThreadInfos() local 146 std::unique_lock<std::shared_mutex> lock(taskInfosMutex_); in GetTaskInfos() local 205 std::lock_guard<std::recursive_mutex> lock(workersMutex_); in CheckForBlockedWorkers() local 251 std::lock_guard<std::recursive_mutex> lock(workersMutex_); in CreateOrDeleteWorkers() local 348 std::unique_lock<std::shared_mutex> lock(taskEnvInfoMutex_); in StoreTaskEnvInfo() local 359 std::unique_lock<std::shared_mutex> lock(taskEnvInfoMutex_); in PopTaskEnvInfo() local 370 std::shared_lock<std::shared_mutex> lock(taskEnvInfoMutex_); in HasTaskEnvInfo() local [all …]
D	worker.cpp	`36 std::lock_guard<std::mutex> lock(worker_->stateMutex_); in ~RunningScope() local 239 std::lock_guard<std::mutex> lock(stateMutex_); in NotifyTaskFinished() local 268 std::lock_guard<std::mutex> lock(worker->currentTaskIdMutex_); in PerformTask() local 333 std::lock_guard<std::mutex> lock(worker->stateMutex_); in PerformTask() local 370 std::lock_guard<std::mutex> lock(worker->currentTaskIdMutex_); in NotifyTaskResult() local`
/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	`53 std::lock_guard<std::mutex> lock(mutex_); in Shutdown() local 78 std::lock_guard<std::mutex> lock(mutex_); in Register() local 111 std::lock_guard<std::mutex> lock(mutex_); in Unregister() local 177 std::lock_guard<std::mutex> lock(mutex_); in OnTimer() local 236 std::lock_guard<std::mutex> lock(mutex_); in EraseUnusedTimerId() local`
D	event_demultiplexer.cpp	`70 std::lock_guard<std::recursive_mutex> lock(mutex_); in UpdateEventHandler() local 119 std::lock_guard<std::recursive_mutex> lock(mutex_); in Polling() local`
D	refbase.cpp	`123 std::lock_guard<std::mutex> lock(trackerMutex); in PrintRefs() local 131 std::lock_guard<std::mutex> lock(trackerMutex); in GetNewTrace() local 139 std::lock_guard<std::mutex> lock(trackerMutex); in PrintTracker() local 153 std::lock_guard<std::mutex> lock(trackerMutex); in EnableTracker() local`
/commonlibrary/memory_utils/libpurgeablemem/cpp/src/
D	purgeable_resource_manager.cpp	132 std::lock_guard<ffrt::mutex> lock(lruCacheMutex_); in ~PurgeableResourceManager() local 152 std::lock_guard<ffrt::mutex> lock(lruCacheMutex_); in BeginAccessPurgeableMem() local 182 std::lock_guard<ffrt::mutex> lock(lruCacheMutex_); in EndAccessPurgeableMem() local 226 std::lock_guard<ffrt::mutex> lock(lruCacheMutex_); in AddResourceInner() local 252 std::lock_guard<ffrt::mutex> lock(lruCacheMutex_); in RemoveResourceInner() local 264 std::lock_guard<ffrt::mutex> lock(lruCacheMutex_); in SetRecentUsedResource() local 274 std::lock_guard<ffrt::mutex> lock(lruCacheMutex_); in SetLruCacheCapacity() local 280 std::lock_guard<ffrt::mutex> lock(lruCacheMutex_); in Clear() local 286 std::lock_guard<ffrt::mutex> lock(lruCacheMutex_); in RemoveLastResource() local 307 std::lock_guard<ffrt::mutex> lock(lruCacheMutex_); in ShowLruCache() local
D	purgeable_mem_base.cpp	`166 std::lock_guard<ffrt::mutex> lock(dataLock_); in BeginReadWithDataLock() local`
/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/ets_utils/js_sys_module/timer/
D	timer.cpp	`90 std::lock_guard<std::mutex> lock(timeLock); in ClearTimer() local 147 std::lock_guard<std::mutex> lock(timeLock); in TimerCallback() local 207 std::lock_guard<std::mutex> lock(timeLock); in SetTimeoutInner() local 234 std::lock_guard<std::mutex> lock(timeLock); in ClearEnvironmentTimer() local 249 std::lock_guard<std::mutex> lock(timeLock); in HasTimer() local`
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/
D	driver.rs	`76 let mut lock = self.wheel.lock().unwrap(); in timer_register() localVariable 81 let mut lock = self.wheel.lock().unwrap(); in timer_cancel() localVariable 97 let mut lock = self.wheel.lock().unwrap(); in run() localVariable`
D	wheel.rs	`387 let lock = TimeDriver::get_ref().wheel.lock().unwrap(); in ut_sleep_drop() localVariable`
/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`
D	utils_event_test.cpp	`711 std::lock_guard<std::mutex> lock(mutex_); in Register() local 754 std::lock_guard<std::mutex> lock(mutex_); in Unregister() local`
/commonlibrary/ets_utils/js_concurrent_module/worker/
D	worker_new.cpp	126 std::lock_guard<std::mutex> lock(g_newWorkersMutex); in WorkerConstructor() local 198 std::lock_guard<std::recursive_mutex> lock(worker->liveStatusLock_); in WorkerConstructor() local 790 std::lock_guard<std::recursive_mutex> lock(worker->liveStatusLock_); in ExecuteInThread() local 833 std::lock_guard<std::recursive_mutex> lock(worker->liveStatusLock_); in ExecuteInThread() local 846 std::lock_guard<std::recursive_mutex> lock(liveStatusLock_); in PrepareForWorkerInstance() local 1271 std::lock_guard<std::recursive_mutex> lock(liveStatusLock_); in HandleException() local 1292 std::lock_guard<std::recursive_mutex> lock(liveStatusLock_); in PostMessageToHostInner() local 1428 std::lock_guard<std::recursive_mutex> lock(liveStatusLock_); in CloseWorkerCallback() local 1451 std::lock_guard<std::mutex> lock(g_newWorkersMutex); in ReleaseWorkerThreadContent() local
D	worker.cpp	106 std::lock_guard<std::recursive_mutex> lock(liveStatusLock_); in PrepareForWorkerInstance() local 194 std::lock_guard<std::recursive_mutex> lock(worker->liveStatusLock_); in ExecuteInThread() local 237 std::lock_guard<std::recursive_mutex> lock(worker->liveStatusLock_); in ExecuteInThread() local 515 std::lock_guard<std::recursive_mutex> lock(liveStatusLock_); in HandleException() local 675 std::lock_guard<std::recursive_mutex> lock(liveStatusLock_); in PostMessageToHostInner() local 802 std::lock_guard<std::mutex> lock(g_workersMutex); in WorkerConstructor() local 859 std::lock_guard<std::recursive_mutex> lock(worker->liveStatusLock_); in WorkerConstructor() local 1240 std::lock_guard<std::recursive_mutex> lock(liveStatusLock_); in CloseWorkerCallback() local 1281 std::lock_guard<std::mutex> lock(g_workersMutex); in ReleaseWorkerThreadContent() local