Searched refs:blocking_pool (Results 1 – 7 of 7) sorted by relevance
/external/rust/crates/tokio/src/runtime/ |
D | builder.rs | 571 let blocking_pool = blocking::create_blocking_pool(self, self.max_blocking_threads); in build_basic_runtime() localVariable 572 let blocking_spawner = blocking_pool.spawner().clone(); in build_basic_runtime() 584 blocking_pool, in build_basic_runtime() 676 …let blocking_pool = blocking::create_blocking_pool(self, self.max_blocking_threads + core_threads); localVariable 677 let blocking_spawner = blocking_pool.spawner().clone(); 696 blocking_pool,
|
D | mod.rs | 279 blocking_pool: BlockingPool, 541 self.blocking_pool.shutdown(Some(duration));
|
/external/crosvm/cros_async/src/ |
D | fd_executor.rs | 264 blocking_pool: BlockingPool, field 275 blocking_pool: Default::default(), in new() 348 self.blocking_pool.spawn(f) in spawn_blocking()
|
D | uring_executor.rs | 306 blocking_pool: BlockingPool, field 320 blocking_pool: Default::default(), in new() 387 self.blocking_pool.spawn(f) in spawn_blocking()
|
/external/crosvm/common/cros_async/src/ |
D | fd_executor.rs | 264 blocking_pool: BlockingPool, field 275 blocking_pool: Default::default(), in new() 348 self.blocking_pool.spawn(f) in spawn_blocking()
|
D | uring_executor.rs | 306 blocking_pool: BlockingPool, field 320 blocking_pool: Default::default(), in new() 387 self.blocking_pool.spawn(f) in spawn_blocking()
|
/external/crosvm/common/cros_asyncv2/src/ |
D | executor.rs | 38 blocking_pool: BlockingPool, field 283 self.shared.lock().blocking_pool.spawn(f) in spawn_blocking()
|