Home
last modified time | relevance | path

Searched refs:CurrentThread (Results 1 – 5 of 5) sorted by relevance

/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/metrics/
H A Druntime.rs59 AsyncHandle::CurrentThread(_) => 1, in workers_num()
82 AsyncHandle::CurrentThread(_) => None, in park_workers_num()
107 AsyncHandle::CurrentThread(_) => None, in active_workers_num()
132 AsyncHandle::CurrentThread(_) => None, in park_workers_list()
155 AsyncHandle::CurrentThread(_) => None, in active_workers_list()
180 AsyncHandle::CurrentThread(_) => None, in overall_workers_list()
262 AsyncHandle::CurrentThread(_) => None, in worker_task_len()
293 AsyncHandle::CurrentThread(_) => None, in worker_total_task_count()
324 AsyncHandle::CurrentThread(_) => None, in worker_poll_count()
351 AsyncHandle::CurrentThread(_) => None, in steal_times()
[all …]
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Dmod.rs64 CurrentThread(CurrentThreadSpawner), enumerator
91 AsyncHandle::CurrentThread(s) => s.handle.clone(), in get_handle()
207 AsyncHandle::CurrentThread(current_thread) => current_thread.spawn(builder, task), in spawn_with_attr()
311 AsyncHandle::CurrentThread(current_thread) => current_thread.block_on(task), in block_on_inner()
331 AsyncHandle::CurrentThread(current_thread) => current_thread.block_on(task), in block_on_inner()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/builder/
H A Dcurrent_thread_builder.rs37 async_spawner: AsyncHandle::CurrentThread(async_spawner), in build()
H A Dmulti_thread_builder.rs290 AsyncHandle::CurrentThread(_) => unreachable!(), in ut_build_global()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/
H A Dcore.rs40 AsyncHandle::CurrentThread(_) => Ok(consumer.consume(par_iter)), in core()