Searched refs:Spawner (Results 1 – 9 of 9) sorted by relevance
| /external/rust/crates/tokio/src/runtime/ |
| D | spawner.rs | 13 pub(crate) enum Spawner { enum
15 Basic(basic_scheduler::Spawner),
17 ThreadPool(thread_pool::Spawner),
20 impl Spawner { impl
24 if let Spawner::ThreadPool(spawner) = self { in shutdown()
32 impl Spawner { impl
40 Spawner::Basic(spawner) => spawner.spawn(future),
42 Spawner::ThreadPool(spawner) => spawner.spawn(future),
|
| D | basic_scheduler.rs | 31 spawner: Spawner,
45 spawner: Spawner,
55 pub(crate) struct Spawner { struct
125 let spawner = Spawner { in new()
150 pub(crate) fn spawner(&self) -> &Spawner { in spawner() argument
380 impl Spawner { implementation
407 impl fmt::Debug for Spawner { implementation
|
| D | handle.rs | 3 use crate::runtime::{blocking, context, driver, Spawner};
17 pub(super) spawner: Spawner,
32 pub(super) blocking_spawner: blocking::Spawner,
|
| D | builder.rs | 2 use crate::runtime::{blocking, driver, Callback, Runtime, Spawner};
445 let spawner = Spawner::Basic(scheduler.spawner().clone()); in build_basic_runtime()
550 let spawner = Spawner::ThreadPool(scheduler.spawner().clone());
|
| D | context.rs | 49 pub(crate) fn spawn_handle() -> Option<crate::runtime::Spawner> {
|
| D | mod.rs | 204 use self::spawner::Spawner;
|
| /external/rust/crates/tokio/src/runtime/thread_pool/ |
| D | mod.rs | 23 spawner: Spawner,
39 pub(crate) struct Spawner { struct
48 let spawner = Spawner { shared }; in new() argument
58 pub(crate) fn spawner(&self) -> &Spawner { in spawner() argument
89 impl Spawner { impl
106 impl fmt::Debug for Spawner { implementation
|
| /external/rust/crates/tokio/src/runtime/blocking/ |
| D | pool.rs | 19 spawner: Spawner,
24 pub(crate) struct Spawner { struct
109 spawner: Spawner { in new()
135 pub(crate) fn spawner(&self) -> &Spawner { in spawner() argument
187 impl Spawner { implementation
361 impl fmt::Debug for Spawner { implementation
|
| D | mod.rs | 7 pub(crate) use pool::{spawn_blocking, BlockingPool, Spawner};
|