Lines Matching refs:Queue
22 pub(crate) struct Queue<T> { struct
40 unsafe impl<T: Send> Sync for Queue<T> {} argument
41 unsafe impl<T: Send> Send for Queue<T> {} implementation
43 impl<T> Queue<T> { implementation
45 pub(crate) fn new() -> Queue<T> { in new()
46 let q = Queue { in new()
204 impl<T> Drop for Queue<T> { implementation
224 struct Queue<T> { struct
225 queue: super::Queue<T>, argument
228 impl<T> Queue<T> { impl
229 pub(crate) fn new() -> Queue<T> { in new()
230 Queue { in new()
231 queue: super::Queue::new(), in new()
266 let q: Queue<i64> = Queue::new(); in push_try_pop_1()
276 let q: Queue<i64> = Queue::new(); in push_try_pop_2()
288 let q: Queue<i64> = Queue::new(); in push_try_pop_many_seq()
302 let q: Queue<i64> = Queue::new(); in push_pop_1()
312 let q: Queue<i64> = Queue::new(); in push_pop_2()
321 let q: Queue<i64> = Queue::new(); in push_pop_many_seq()
335 let q: Queue<i64> = Queue::new(); in push_try_pop_many_spsc()
359 fn recv(_t: i32, q: &Queue<i64>) { in push_try_pop_many_spmc()
373 let q: Queue<i64> = Queue::new(); in push_try_pop_many_spmc()
397 let q: Queue<LR> = Queue::new(); in push_try_pop_many_mpmc()
438 let q: Queue<i64> = Queue::new(); in push_pop_many_spsc()
459 let q: Queue<i64> = Queue::new(); in is_empty_dont_pop()