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

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

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