tokio/runtime/scheduler/multi_thread_alt/handle/
metrics.rs

1use super::Handle;
2
3use crate::runtime::{SchedulerMetrics, WorkerMetrics};
4
5impl Handle {
6    pub(crate) fn num_workers(&self) -> usize {
7        self.shared.worker_metrics.len()
8    }
9
10    pub(crate) fn num_blocking_threads(&self) -> usize {
11        // workers are currently spawned using spawn_blocking
12        self.blocking_spawner
13            .num_threads()
14            .saturating_sub(self.num_workers())
15    }
16
17    pub(crate) fn num_idle_blocking_threads(&self) -> usize {
18        self.blocking_spawner.num_idle_threads()
19    }
20
21    pub(crate) fn num_alive_tasks(&self) -> usize {
22        self.shared.owned.num_alive_tasks()
23    }
24
25    cfg_64bit_metrics! {
26        pub(crate) fn spawned_tasks_count(&self) -> u64 {
27            self.shared.owned.spawned_tasks_count()
28        }
29    }
30
31    pub(crate) fn scheduler_metrics(&self) -> &SchedulerMetrics {
32        &self.shared.scheduler_metrics
33    }
34
35    pub(crate) fn worker_metrics(&self, worker: usize) -> &WorkerMetrics {
36        &self.shared.worker_metrics[worker]
37    }
38
39    pub(crate) fn injection_queue_depth(&self) -> usize {
40        self.shared.injection_queue_depth()
41    }
42
43    pub(crate) fn worker_local_queue_depth(&self, worker: usize) -> usize {
44        self.shared.worker_local_queue_depth(worker)
45    }
46
47    pub(crate) fn blocking_queue_depth(&self) -> usize {
48        self.blocking_spawner.queue_depth()
49    }
50}