Searched defs:queue (Results 1 – 8 of 8) 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
68 void Dequeue(napi_env env, MsgQueue*& queue) in Dequeue()
1078 MsgQueue* queue = nullptr; in GetMessageQueue() local1091 MsgQueue* queue = nullptr; in GetMessageQueueFromCallbackInfo() local
91 queue: VecDeque<(Header, String)>, field
116 queue: VecDeque<DynamicField>, field
1800 MessageQueue queue; variable1810 MessageQueue queue; variable1823 MarkedMessageQueue queue; variable