Home
last modified time | relevance | path

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/
Dmetrics.rs12 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/
Dmetrics.rs29 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/
Dmod.rs50 blocking_spawner: blocking::Spawner, in new()
58 blocking_spawner, in new()
Dhandle.rs26 pub(crate) blocking_spawner: blocking::Spawner, field
Dworker.rs260 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/
Dmod.rs61 blocking_spawner: blocking::Spawner, in new()
70 blocking_spawner, in new()
Dhandle.rs28 pub(crate) blocking_spawner: blocking::Spawner, field
Dworker.rs245 blocking_spawner: blocking::Spawner, in create()
306 blocking_spawner, in create()
/external/rust/android-crates-io/crates/tokio/src/runtime/
Dbuilder.rs1371 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,
Dhandle.rs226 self.inner.blocking_spawner().spawn_blocking(self, func) in spawn_blocking()
/external/rust/android-crates-io/crates/tokio/src/runtime/scheduler/current_thread/
Dmod.rs44 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/
Dbuilder.rs214 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/
Dmod.rs112 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/
Dpool.rs203 rt.inner.blocking_spawner().spawn_mandatory_blocking(&rt, func)
469 rt.inner.blocking_spawner().inner.run(id); in spawn_thread()