1 use super::Shared;
2 
3 impl Shared {
injection_queue_depth(&self) -> usize4     pub(crate) fn injection_queue_depth(&self) -> usize {
5         self.inject.len()
6     }
7 }
8 
9 cfg_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 }
16