Home
last modified time | relevance | path

Searched refs:JoinHandle (Results 1 – 25 of 32) sorted by relevance

12

/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/
H A Djoin_handle.rs47 pub struct JoinHandle<R> { struct
52 unsafe impl<R: Send> Send for JoinHandle<R> {} argument
53 unsafe impl<R: Send> Sync for JoinHandle<R> {} implementation
55 impl<R> JoinHandle<R> { implementation
56 pub(crate) fn new(raw: RawTask) -> JoinHandle<R> { in new()
57 JoinHandle { in new()
96 impl<R> Unpin for JoinHandle<R> {} implementation
98 impl<R> Future for JoinHandle<R> { implementation
131 impl<R> Drop for JoinHandle<R> { implementation
H A Dmod.rs29 pub use join_handle::JoinHandle;
102 ) -> (Task, JoinHandle<T::Output>) in create_task()
110 let join = JoinHandle::new(raw); in create_task()
141 pub fn spawn<T, R>(task: T) -> JoinHandle<R> in spawn()
151 pub fn spawn_blocking<T, R>(task: T) -> JoinHandle<R> in spawn_blocking()
H A Dbuilder.rs24 use crate::task::{JoinHandle, Qos};
62 pub fn spawn<T, R>(&self, task: T) -> JoinHandle<R> in spawn()
72 pub fn spawn_blocking<T, R>(&self, task: T) -> JoinHandle<R> in spawn_blocking()
/ohos5.0/base/msdp/device_status/rust/modules/scheduler/sys/src/
H A Dtask.rs19 use ylong_runtime::task::JoinHandle;
23 join_handle: Option<JoinHandle<R>>,
26 impl<R> From<JoinHandle<R>> for TaskHandle<R> {
27 fn from(value: JoinHandle<R>) -> Self in from()
H A Dscheduler.rs69 handle: ylong_runtime::task::JoinHandle<()>,
75 fn new(raw: Arc<dyn IEpollHandler>, handle: ylong_runtime::task::JoinHandle<()>) -> Self in new()
482 join_handle: Option<std::thread::JoinHandle<()>>,
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/
H A Dspawn.rs17 use crate::task::join_handle::JoinHandle;
47 pub(crate) fn spawn_blocking<T, R>(builder: &TaskBuilder, task: T) -> JoinHandle<R>
60 pub(crate) fn spawn_blocking<T, R>(builder: &TaskBuilder, task: T) -> JoinHandle<R> in spawn_blocking()
73 pub(crate) fn spawn_async<T, R>(builder: &TaskBuilder, task: T) -> JoinHandle<R> in spawn_async()
/ohos5.0/base/security/asset/services/core_service/src/
H A Dunload_handler.rs21 use ylong_runtime::task::JoinHandle;
24 task: Option<JoinHandle<()>>,
42 pub(crate) fn update_task(&mut self, new_task: JoinHandle<()>) { in update_task() argument
/ohos5.0/foundation/communication/ipc/interfaces/innerkits/rust/src/ipc_async/
H A Dmod.rs22 use ylong_runtime::task::JoinHandle;
55 fn spawn<T, R>(task: T) -> JoinHandle<R> in spawn()
62 fn spawn_blocking<T, R>(task: T) -> JoinHandle<R> in spawn_blocking()
H A Dipc_ylong.rs67 fn spawn<T, R>(task: T) -> JoinHandle<R> in spawn()
76 fn spawn_blocking<T, R>(task: T) -> JoinHandle<R> in spawn_blocking()
/ohos5.0/base/request/request/services/src/manage/scheduler/queue/
H A Dkeeper.rs18 use ylong_runtime::task::JoinHandle;
33 handle: Option<JoinHandle<()>>,
85 fn count_down(tx: UnboundedSender<TaskManagerEvent>) -> JoinHandle<()> { in count_down() argument
H A Dmod.rs25 use ylong_runtime::task::JoinHandle;
250 join_handle: JoinHandle<()>,
254 fn new(abort_flag: Arc<AtomicBool>, join_handle: JoinHandle<()>) -> Self { in new()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/
H A Dcore.rs17 use crate::task::{JoinHandle, TaskBuilder};
131 ) -> JoinHandle<Result<C::Output, ScheduleError>> in spawn_task()
193 ) -> JoinHandle<Result<C::Output, ScheduleError>> in spawn_task_ffrt()
205 let join_handle = JoinHandle::new(raw_task); in spawn_task_ffrt()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Dmod.rs29 use crate::task::{JoinHandle, Task, TaskBuilder};
191 pub fn spawn<T, R>(&self, task: T) -> JoinHandle<R> in spawn()
200 pub(crate) fn spawn_with_attr<T, R>(&self, task: T, builder: &TaskBuilder) -> JoinHandle<R> in spawn_with_attr()
237 pub fn spawn_blocking<T, R>(&self, task: T) -> JoinHandle<R> in spawn_blocking()
H A Dasync_pool.rs32 use crate::task::{JoinHandle, Task, TaskBuilder, VirtualTableType};
494 pub(crate) fn spawn<T>(&self, builder: &TaskBuilder, task: T) -> JoinHandle<T::Output> in spawn()
549 ) -> JoinHandle<T::Output> in spawn_with_ref()
556 let handle = JoinHandle::new(raw_task); in spawn_with_ref()
624 use crate::task::{JoinHandle, Task, TaskBuilder, VirtualTableType};
694 ) -> (Task, JoinHandle<T::Output>) in create_task()
H A Dblocking_pool.rs27 use crate::task::{JoinHandle, TaskBuilder, VirtualTableType};
163 worker_threads: VecDeque<(usize, thread::JoinHandle<()>)>,
194 pub(crate) fn spawn_blocking<T, R>(&self, builder: &TaskBuilder, task: T) -> JoinHandle<R> in spawn_blocking()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dsemaphore_test.rs18 use ylong_runtime::task::JoinHandle;
104 let mut tasks: Vec<JoinHandle<()>> = Vec::new(); in sdv_auto_release_sem_stress_test()
138 let mut tasks: Vec<JoinHandle<()>> = Vec::new(); in sdv_async_stress_test()
H A Dmpsc_test.rs274 use ylong_runtime::task::JoinHandle; in sdv_multi_send_recv_test()
277 let mut tasks: Vec<JoinHandle<()>> = Vec::new(); in sdv_multi_send_recv_test()
297 let mut tasks: Vec<JoinHandle<()>> = Vec::new(); in sdv_multi_send_recv_test()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/ffrt/
H A Dspawner.rs23 use crate::task::{JoinHandle, Task, TaskBuilder, VirtualTableType};
66 pub fn spawn<F>(task: F, builder: &TaskBuilder) -> JoinHandle<F::Output> in spawn()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/
H A Dsemaphore.rs351 use crate::task::JoinHandle;
433 let mut tasks: Vec<JoinHandle<()>> = Vec::new(); in ut_auto_release_sem_stress_test()
466 let mut tasks: Vec<JoinHandle<()>> = Vec::new(); in ut_async_stress_test()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/dns/
H A Dresolver.rs24 use crate::runtime::JoinHandle;
75 inner: JoinHandle<Result<ResolvedAddrs, Error>>,
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/
H A Dlib.rs87 task::{spawn_blocking, JoinHandle},
95 task::JoinHandle,
/ohos5.0/base/request/request/services/src/manage/scheduler/state/
H A Dmod.rs18 use ylong_runtime::task::JoinHandle;
33 background_timeout: HashMap<u64, JoinHandle<()>>,
/ohos5.0/base/request/request/services/src/utils/
H A Dmod.rs32 use ylong_runtime::task::JoinHandle;
98 ) -> JoinHandle<()> { in runtime_spawn() argument
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/
H A Dstdio.rs18 use crate::task::JoinHandle;
24 Poll(JoinHandle<(io::Result<usize>, BufInner, T)>),
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/
H A Daddr.rs21 use crate::task::JoinHandle;
55 Block(JoinHandle<io::Result<I>>),

12