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