Struct Mpsc 

pub struct Mpsc<T> { /* private fields */ }

The queue (see the module documentation).

Implementations

impl<T> Mpsc<T>

pub const fn new() -> Mpsc<T>

An empty queue.

pub fn push(&self, value: T)

Adds value (any thread). Sequentially consistent, so a consumer that announces it is about to sleep and then checks Mpsc::is_empty either sees the value or is seen by the producer’s following check of that announcement.

pub fn is_empty(&self) -> bool

Whether the queue looks empty (a push may be landing concurrently).

pub fn take(&self, into: &mut Vec<T>)

Moves every queued value into into, oldest first (the consumer thread).

Trait Implementations

impl<T> Debug for Mpsc<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T> Default for Mpsc<T>

fn default() -> Self

Returns the “default value” for a type.

impl<T> Drop for Mpsc<T>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl<T: Send> Send for Mpsc<T>

impl<T: Send> Sync for Mpsc<T>