Searched refs:CancellableBlockingPool (Results 1 – 3 of 3) sorted by relevance
27 static EXECUTOR: Lazy<CancellableBlockingPool> =28 Lazy::new(|| CancellableBlockingPool::new(256, Duration::from_secs(10)));126 pub struct CancellableBlockingPool { struct130 impl CancellableBlockingPool { argument142 pub fn new(max_threads: usize, keepalive: Duration) -> CancellableBlockingPool { in new() argument143 CancellableBlockingPool { in new()153 pub fn with_capacity(max_threads: usize, keepalive: Duration) -> CancellableBlockingPool { in with_capacity() argument154 CancellableBlockingPool { in with_capacity()311 impl Default for CancellableBlockingPool { implementation312 fn default() -> CancellableBlockingPool { in default()[all …]
36 use crate::CancellableBlockingPool;122 blocking_pool: CancellableBlockingPool,146 blocking_pool: CancellableBlockingPool::new( in new()
87 pub use blocking::CancellableBlockingPool;