Home
last modified time | relevance | path

Searched refs:blocking_pool (Results 1 – 7 of 7) sorted by relevance

/external/rust/crates/tokio/src/runtime/
Dbuilder.rs571 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,
Dmod.rs279 blocking_pool: BlockingPool,
541 self.blocking_pool.shutdown(Some(duration));
/external/crosvm/cros_async/src/
Dfd_executor.rs264 blocking_pool: BlockingPool, field
275 blocking_pool: Default::default(), in new()
348 self.blocking_pool.spawn(f) in spawn_blocking()
During_executor.rs306 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/
Dfd_executor.rs264 blocking_pool: BlockingPool, field
275 blocking_pool: Default::default(), in new()
348 self.blocking_pool.spawn(f) in spawn_blocking()
During_executor.rs306 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/
Dexecutor.rs38 blocking_pool: BlockingPool, field
283 self.shared.lock().blocking_pool.spawn(f) in spawn_blocking()