Lines Matching refs:Queue
22 pub 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 fn new() -> Queue<T> { in new()
46 let q = Queue { in new()
196 impl<T> Drop for Queue<T> { implementation
216 struct Queue<T> { struct
217 queue: super::Queue<T>, argument
220 impl<T> Queue<T> { impl
221 pub fn new() -> Queue<T> { in new()
222 Queue { in new()
223 queue: super::Queue::new(), in new()
258 let q: Queue<i64> = Queue::new(); in push_try_pop_1()
268 let q: Queue<i64> = Queue::new(); in push_try_pop_2()
280 let q: Queue<i64> = Queue::new(); in push_try_pop_many_seq()
294 let q: Queue<i64> = Queue::new(); in push_pop_1()
304 let q: Queue<i64> = Queue::new(); in push_pop_2()
313 let q: Queue<i64> = Queue::new(); in push_pop_many_seq()
327 let q: Queue<i64> = Queue::new(); in push_try_pop_many_spsc()
351 fn recv(_t: i32, q: &Queue<i64>) { in push_try_pop_many_spmc()
365 let q: Queue<i64> = Queue::new(); in push_try_pop_many_spmc()
389 let q: Queue<LR> = Queue::new(); in push_try_pop_many_mpmc()
430 let q: Queue<i64> = Queue::new(); in push_pop_many_spsc()
451 let q: Queue<i64> = Queue::new(); in is_empty_dont_pop()