tokio/runtime/scheduler/multi_thread_alt/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    pub(crate) fn worker_local_queue_depth(&self, worker: usize) -> usize {
9        self.remotes[worker].steal.len()
10    }
11}