Searched refs:blocking_pool (Results 1 – 3 of 3) sorted by relevance
427 blocking_pool.inner.stack_size, in ut_blocking_pool_new()431 blocking_pool.inner.max_thread_num, in ut_blocking_pool_new()435 blocking_pool.inner.keep_alive_time, in ut_blocking_pool_new()439 blocking_pool.inner.max_permanent_thread_num, in ut_blocking_pool_new()459 assert!(!blocking_pool.shutdown(Duration::from_secs(3))); in ut_blocking_pool_shutdown()463 let spawner_inner_clone = blocking_pool.inner.clone(); in ut_blocking_pool_shutdown()468 assert!(blocking_pool.shutdown(Duration::from_secs(3))); in ut_blocking_pool_shutdown()472 let spawner_inner_clone = blocking_pool.inner.clone(); in ut_blocking_pool_shutdown()478 assert!(!blocking_pool.shutdown(Duration::from_secs(0))); in ut_blocking_pool_shutdown()507 blocking_pool in ut_blocking_pool_spawner_create_permanent_threads()[all …]
40 pub(crate) mod blocking_pool;47 use crate::executor::blocking_pool::BlockPoolSpawner;
44 use crate::executor::blocking_pool::BlockPoolSpawner;