Home
last modified time | relevance | path

Searched defs:join_handle (Results 1 – 8 of 8) sorted by relevance

/ohos5.0/base/msdp/device_status/rust/modules/scheduler/sys/src/
H A Dtask.rs23 join_handle: Option<JoinHandle<R>>, field
H A Dscheduler.rs482 join_handle: Option<std::thread::JoinHandle<()>>, field
492 let join_handle = std::thread::spawn(move || { in new() localVariable
510 let join_handle = ylong_runtime::spawn( in add_epoll_handler() localVariable
/ohos5.0/base/request/request/services/src/manage/scheduler/queue/
H A Dmod.rs92 let join_handle = runtime_spawn(async move { in try_restart() localVariable
220 let join_handle = runtime_spawn(async move { in reschedule_inner() localVariable
250 join_handle: JoinHandle<()>, field
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Dcurrent_thread.rs494 let join_handle = spawner.spawn(ylong_tcp_server(tx)); in ut_current_thread_io() localVariable
501 let join_handle = spawner.spawn(ylong_tcp_client(rx)); in ut_current_thread_io() localVariable
H A Dblocking_pool.rs180 let join_handle = builder.spawn(move || inner.run(worker_id)); in create_permanent_threads() localVariable
240 let join_handle = builder.spawn(move || inner.run(worker_id)); in spawn() localVariable
H A Dasync_pool.rs101 let join_handle = self.handles.read().unwrap(); in wake_up_all() localVariable
586 let mut join_handle = self.exe_mng_info.handles.write().unwrap(); in release() localVariable
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/
H A Dcore.rs205 let join_handle = JoinHandle::new(raw_task); in spawn_task_ffrt() localVariable
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/
H A Dmod.rs17 pub mod join_handle; module