Searched refs:async_spawner (Results 1 – 5 of 5) sorted by relevance
57 match &self.runtime.async_spawner { in workers_num()80 match &self.runtime.async_spawner { in park_workers_num()105 match &self.runtime.async_spawner { in active_workers_num()130 match &self.runtime.async_spawner { in park_workers_list()153 match &self.runtime.async_spawner { in active_workers_list()178 match &self.runtime.async_spawner { in overall_workers_list()214 match &self.runtime.async_spawner { in global_queue_length()237 match &self.runtime.async_spawner { in global_queue_total_task_count()260 match &self.runtime.async_spawner { in worker_task_len()291 match &self.runtime.async_spawner { in worker_total_task_count()[all …]
83 pub(crate) async_spawner: AsyncHandle,89 match &self.async_spawner { in get_handle()114 async_spawner: AsyncHandle::MultiThread(s), in global_default_async()120 async_spawner: AsyncHandle::FfrtMultiThread, in global_default_async()205 match &self.async_spawner { in spawn_with_attr()209 AsyncHandle::MultiThread(async_spawner) => async_spawner.spawn(builder, task), in spawn_with_attr()309 let ret = match &self.async_spawner { in block_on_inner()329 match &self.async_spawner { in block_on_inner()
35 let async_spawner = CurrentThreadSpawner::new(); in build() localVariable37 async_spawner: AsyncHandle::CurrentThread(async_spawner), in build()
229 let async_spawner = initialize_async_spawner(self)?; in build() localVariable232 async_spawner: AsyncHandle::MultiThread(async_spawner), in build()289 match &async_pool.async_spawner { in ut_build_global()
38 match runtime.async_spawner { in core()