Searched defs:queue (Results 1 – 5 of 5) sorted by relevance
19 pub(crate) mod queue; module
95 let queue = Queue::new(); in unbounded_channel() localVariable
47 let mut queue = self.inner.lock().unwrap(); in schedule() localVariable56 let mut queue = self.inner.lock().unwrap(); in pop() localVariable136 let mut queue = self.scheduler.inner.lock().unwrap(); in spawn() localVariable
142 queue: VecDeque<Task>, field
91 queue: VecDeque<(Header, String)>, field