Searched defs:queue (Results 1 – 6 of 6) sorted by relevance
16 pub(crate) mod queue; module99 let queue = Queue::new(); in unbounded_channel() localVariable
60 let mut queue = self.inner.lock().unwrap(); in schedule() localVariable74 let mut queue = self.inner.lock().unwrap(); in pop() localVariable258 let mut queue = self.scheduler.inner.lock().unwrap(); in spawn() localVariable
142 queue: VecDeque<Task>, field
91 queue: VecDeque<(Header, String)>, field
116 queue: VecDeque<DynamicField>, field
1827 MessageQueue queue; variable1837 MessageQueue queue; variable1850 MarkedMessageQueue queue; variable