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

Help
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            // workers are currently spawned using spawn_blocking
34            self.blocking_spawner
35                .num_threads()
36                .saturating_sub(self.num_workers())
37        }
38
39        pub(crate) fn num_idle_blocking_threads(&self) -> usize {
40            self.blocking_spawner.num_idle_threads()
41        }
42
43        pub(crate) fn scheduler_metrics(&self) -> &SchedulerMetrics {
44            &self.shared.scheduler_metrics
45        }
46
47        pub(crate) fn worker_local_queue_depth(&self, worker: usize) -> usize {
48            self.shared.worker_local_queue_depth(worker)
49        }
50
51        pub(crate) fn blocking_queue_depth(&self) -> usize {
52            self.blocking_spawner.queue_depth()
53        }
54    }
55}
tokio/runtime/scheduler/multi_thread/handle/metrics.rs

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