Searched refs:sync (Results 1 - 25 of 59) sorted by relevance

123

/base/request/request/services/src/
H A D	lib.rs	74 static ONCE: std::sync::Once = std::sync::Once::new(); 92 DB_LOCK = std::sync::Mutex::new(()); 101 _inner: std::sync::MutexGuard<'a, ()>, 112 static mut DB_LOCK: std::sync::Mutex<()> = std::sync::Mutex::new(());
H A D	ability.rs	16 use std::sync::atomic::{AtomicBool, Ordering}; 17 use std::sync::{Arc, Mutex};
/base/request/request/pre_download/native/src/cache/
H A D	manage.rs	18 use std::sync::atomic::{AtomicBool, AtomicUsize, Ordering}; 19 use std::sync::{Arc, LazyLock, Mutex, Once, RwLock};
/base/request/request/services/src/task/
H A D	operator.rs	16 use std::sync::atomic::{AtomicBool, Ordering}; 17 use std::sync::Arc;
H A D	upload.rs	17 use std::sync::atomic::{AtomicBool, Ordering}; 18 use std::sync::Arc; 445 use std::sync::atomic::AtomicBool; 446 use std::sync::Arc; 449 use ylong_runtime::sync::mpsc::unbounded_channel;
/base/msdp/device_status/rust/modules/scheduler/sys/src/
H A D	lib.rs	44 use std::sync::Arc; 45 use std::sync::atomic::{ AtomicUsize, Ordering };
/base/request/request/services/src/manage/scheduler/queue/
H A D	running_task.rs	15 use std::sync::atomic::AtomicBool; 16 use std::sync::Arc;
H A D	keeper.rs	14 use std::sync::{Arc, Mutex}; 17 use ylong_runtime::sync::mpsc::UnboundedSender;
/base/hiviewdfx/faultloggerd/interfaces/rust/stacktrace/
H A D	lib.rs	21 use std::sync::Mutex;
/base/request/request/services/src/manage/
H A D	database.rs	18 use std::sync::{Arc, Mutex, Once};
H A D	account.rs	14 use std::sync::atomic::{AtomicBool, AtomicI32, Ordering}; 15 use std::sync::{Mutex, Once}; 272 use ylong_runtime::sync::mpsc;
H A D	app_state.rs	15 use std::sync::Once;
/base/request/request/services/src/utils/
H A D	task_id_generator.rs	15 use std::sync::atomic::{AtomicU32, Ordering};
/base/security/asset/services/common/src/
H A D	counter.rs	19 use std::sync::{Arc, Mutex};
/base/security/asset/services/core_service/src/
H A D	unload_handler.rs	19 use std::sync::{Arc, Mutex};
/base/request/request/services/src/manage/scheduler/state/
H A D	updater.rs	15 use std::sync::atomic::Ordering;
/base/request/request/services/src/service/run_count/
H A D	manager.rs	16 use ylong_runtime::sync::mpsc::{unbounded_channel, UnboundedReceiver, UnboundedSender}; 17 use ylong_runtime::sync::oneshot::{self, Sender};
H A D	mod.rs	22 use ylong_runtime::sync::oneshot::Sender;
/base/msdp/device_status/rust/services/sys/src/
H A D	service.rs	23 use std::sync::{ Mutex, Once };
/base/update/updater/services/hwfault_retry/
H A D	hwfault_retry.cpp	80 sync(); in RebootRetry()
/base/msdp/device_status/rust/subsystem/device_profile/sys/src/
H A D	device_profile.rs	20 use std::{ ffi::{ c_char, c_int, CString }, sync::Arc };
/base/security/asset/services/crypto_manager/src/
H A D	crypto_manager.rs	20 sync::{Arc, Mutex},
/base/security/device_auth/frameworks/inc/standard/
H A D	ipc_dev_auth_stub.h	43 static void ActCallback(int32_t objIdx, int32_t callbackId, bool sync,
/base/time/time_service/framework/js/napi/common/include/
H A D	napi_work.h	38 bool sync = false);
/base/request/request/services/src/service/client/
H A D	manager.rs	16 use ylong_runtime::sync::mpsc::{unbounded_channel, UnboundedReceiver, UnboundedSender}; 17 use ylong_runtime::sync::oneshot::Sender;

Completed in 10 milliseconds

123

Indexes created Thu Nov 07 10:32:03 CST 2024