Lines Matching refs:Queue
23 pub struct Queue<T> { struct
41 unsafe impl<T: Send> Sync for Queue<T> {} argument
42 unsafe impl<T: Send> Send for Queue<T> {} implementation
44 impl<T> Queue<T> { impl
46 pub fn new() -> Queue<T> { in new()
47 let q = Queue { in new()
192 impl<T> Drop for Queue<T> { implementation
212 struct Queue<T> { struct
213 queue: super::Queue<T>, argument
216 impl<T> Queue<T> { impl
217 pub fn new() -> Queue<T> { in new()
218 Queue { in new()
219 queue: super::Queue::new(), in new()
254 let q: Queue<i64> = Queue::new(); in push_try_pop_1()
264 let q: Queue<i64> = Queue::new(); in push_try_pop_2()
276 let q: Queue<i64> = Queue::new(); in push_try_pop_many_seq()
290 let q: Queue<i64> = Queue::new(); in push_pop_1()
300 let q: Queue<i64> = Queue::new(); in push_pop_2()
309 let q: Queue<i64> = Queue::new(); in push_pop_many_seq()
323 let q: Queue<i64> = Queue::new(); in push_try_pop_many_spsc()
347 fn recv(_t: i32, q: &Queue<i64>) { in push_try_pop_many_spmc()
361 let q: Queue<i64> = Queue::new(); in push_try_pop_many_spmc()
385 let q: Queue<LR> = Queue::new(); in push_try_pop_many_mpmc()
426 let q: Queue<i64> = Queue::new(); in push_pop_many_spsc()
447 let q: Queue<i64> = Queue::new(); in is_empty_dont_pop()