pub struct Queue<T> {
state: Mutex<State<T>>,
popper_cv: Condvar,
bounded_cv: Condvar,
bound: usize,
}
Expand description
A simple, threadsafe, queue of items of type T
This is a sort of channel where any thread can push to a queue and any thread can pop from a queue.
This supports both bounded and unbounded operations. push
will never block,
and allows the queue to grow without bounds. push_bounded
will block if the
queue is over capacity, and will resume once there is enough capacity.
Fields§
§state: Mutex<State<T>>
§popper_cv: Condvar
§bounded_cv: Condvar
§bound: usize
Implementations§
Auto Trait Implementations§
impl<T> RefUnwindSafe for Queue<T>
impl<T> Send for Queue<T>where
T: Send,
impl<T> Sync for Queue<T>where
T: Send,
impl<T> Unpin for Queue<T>where
T: Unpin,
impl<T> UnwindSafe for Queue<T>
Blanket Implementations§
Layout§
Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...)
attributes. Please see the Rust Reference’s “Type Layout” chapter for details on type layout guarantees.
Size: 56 bytes