Searched refs:blocking_spawner (Results 1 – 14 of 14) sorted by relevance
| /external/rust/android-crates-io/crates/tokio/src/runtime/scheduler/multi_thread_alt/handle/ |
| D | metrics.rs | 12 self.blocking_spawner in num_blocking_threads()
18 self.blocking_spawner.num_idle_threads() in num_idle_blocking_threads()
48 self.blocking_spawner.queue_depth() in blocking_queue_depth()
|
| /external/rust/android-crates-io/crates/tokio/src/runtime/scheduler/multi_thread/handle/ |
| D | metrics.rs | 29 self.blocking_spawner
35 self.blocking_spawner.num_idle_threads()
51 self.blocking_spawner.queue_depth()
|
| /external/rust/android-crates-io/crates/tokio/src/runtime/scheduler/multi_thread_alt/ |
| D | mod.rs | 50 blocking_spawner: blocking::Spawner, in new()
58 blocking_spawner, in new()
|
| D | handle.rs | 26 pub(crate) blocking_spawner: blocking::Spawner, field
|
| D | worker.rs | 260 blocking_spawner: blocking::Spawner, in create()
331 blocking_spawner, in create()
346 .blocking_spawner in create()
|
| /external/rust/android-crates-io/crates/tokio/src/runtime/scheduler/multi_thread/ |
| D | mod.rs | 61 blocking_spawner: blocking::Spawner, in new()
70 blocking_spawner, in new()
|
| D | handle.rs | 28 pub(crate) blocking_spawner: blocking::Spawner, field
|
| D | worker.rs | 245 blocking_spawner: blocking::Spawner, in create()
306 blocking_spawner, in create()
|
| /external/rust/android-crates-io/crates/tokio/src/runtime/ |
| D | builder.rs | 1371 let blocking_spawner = blocking_pool.spawner().clone(); in build_current_thread_runtime_components() localVariable
1384 blocking_spawner, in build_current_thread_runtime_components()
1524 let blocking_spawner = blocking_pool.spawner().clone(); localVariable
1534 blocking_spawner,
1573 let blocking_spawner = blocking_pool.spawner().clone(); localVariable
1583 blocking_spawner,
|
| D | handle.rs | 226 self.inner.blocking_spawner().spawn_blocking(self, func) in spawn_blocking()
|
| /external/rust/android-crates-io/crates/tokio/src/runtime/scheduler/current_thread/ |
| D | mod.rs | 44 pub(crate) blocking_spawner: blocking::Spawner, field
131 blocking_spawner: blocking::Spawner, in new()
158 blocking_spawner, in new()
587 self.blocking_spawner.num_threads()
591 self.blocking_spawner.num_idle_threads()
595 self.blocking_spawner.queue_depth()
|
| /external/rust/android-crates-io/crates/tokio/src/task/ |
| D | builder.rs | 214 handle.inner.blocking_spawner().spawn_blocking_inner( in spawn_blocking_on()
221 handle.inner.blocking_spawner().spawn_blocking_inner( in spawn_blocking_on()
|
| /external/rust/android-crates-io/crates/tokio/src/runtime/scheduler/ |
| D | mod.rs | 112 pub(crate) fn blocking_spawner(&self) -> &blocking::Spawner {
113 match_flavor!(self, Handle(h) => &h.blocking_spawner)
|
| /external/rust/android-crates-io/crates/tokio/src/runtime/blocking/ |
| D | pool.rs | 203 rt.inner.blocking_spawner().spawn_mandatory_blocking(&rt, func)
469 rt.inner.blocking_spawner().inner.run(id); in spawn_thread()
|