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()
1032 MsgQueue* queue = nullptr; in GetMessageQueue() local1045 MsgQueue* queue = nullptr; in GetMessageQueueFromCallbackInfo() local
91 queue: VecDeque<(Header, String)>, field
96 queue: VecDeque<(Field, String)>, field
780 MessageQueue queue; variable790 MessageQueue queue; variable803 MarkedMessageQueue queue; variable