Searched defs:BlockingPool (Results 1 – 4 of 4) sorted by relevance
199 pub struct BlockingPool { struct203 impl BlockingPool { impl217 pub fn new(max_threads: usize, keepalive: Duration) -> BlockingPool { in new()239 pub fn with_capacity(max_threads: usize, keepalive: Duration) -> BlockingPool { in with_capacity()334 impl Default for BlockingPool { implementation340 impl Drop for BlockingPool { implementation
17 pub(crate) struct BlockingPool { struct18 spawner: Spawner,19 shutdown_rx: shutdown::Receiver,207 impl BlockingPool { implementation208 pub(crate) fn new(builder: &Builder, thread_cap: usize) -> BlockingPool { in new()276 impl Drop for BlockingPool { implementation282 impl fmt::Debug for BlockingPool { implementation
24 pub(crate) fn create_blocking_pool(builder: &Builder, thread_cap: usize) -> BlockingPool { in create_blocking_pool()
91 blocking_pool: BlockingPool, in from_parts()