Searched refs:BlockPoolSpawner (Results 1 – 3 of 3) sorted by relevance
33 pub(crate) struct BlockPoolSpawner { struct37 impl Drop for BlockPoolSpawner { argument43 impl BlockPoolSpawner { implementation44 pub fn new(builder: &CommonBuilder) -> BlockPoolSpawner { in new() argument51 BlockPoolSpawner { in new()169 impl BlockPoolSpawner { impl425 let blocking_pool = BlockPoolSpawner::new(&thread_pool_builder.common); in ut_blocking_pool_new()457 let mut blocking_pool = BlockPoolSpawner::new(&thread_pool_builder.common); in ut_blocking_pool_shutdown()493 let blocking_pool = BlockPoolSpawner::new(&thread_pool_builder.common); in ut_blocking_pool_spawner_create_permanent_threads()500 let blocking_pool = BlockPoolSpawner::new(&common.common); in ut_blocking_pool_spawner_create_permanent_threads()[all …]
47 use crate::executor::blocking_pool::BlockPoolSpawner;129 pub(crate) fn global_default_blocking() -> &'static BlockPoolSpawner { in global_default_blocking()130 static mut GLOBAL_DEFAULT_BLOCKING: MaybeUninit<BlockPoolSpawner> = MaybeUninit::uninit(); in global_default_blocking()
44 use crate::executor::blocking_pool::BlockPoolSpawner;135 ) -> Result<BlockPoolSpawner, ScheduleError> {136 let blocking_spawner = BlockPoolSpawner::new(builder);