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

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

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