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

1use super::Shared;
2
3impl Shared {
4    pub(crate) fn injection_queue_depth(&self) -> usize {
5        self.inject.len()
6    }
7}
8
9cfg_unstable_metrics! {
10    impl Shared {
11        pub(crate) fn worker_local_queue_depth(&self, worker: usize) -> usize {
12            self.remotes[worker].steal.len()
13        }
14    }
15}