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§
source§impl<T> Queue<T>
impl<T> Queue<T>
sourcepub fn push(&self, item: T)
pub fn push(&self, item: T)
Pushes an item onto the queue, regardless of the capacity of the queue.
sourcepub fn push_bounded(&self, item: T)
pub fn push_bounded(&self, item: T)
Pushes an item onto the queue, blocking if the queue is full.
sourcepub fn pop(&self, timeout: Duration) -> Option<T>
pub fn pop(&self, timeout: Duration) -> Option<T>
Pops an item from the queue, blocking if the queue is empty.
sourcepub fn try_pop_all(&self) -> Vec<T>
pub fn try_pop_all(&self) -> Vec<T>
Pops all items from the queue without blocking.
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§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> WithSubscriber for T
impl<T> WithSubscriber for T
source§fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,
source§fn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
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: 88 bytes