Struct mpmcpq::PriorityQueue

pub struct PriorityQueue<K, P> where
    K: Send,
    P: PartialOrd + Default + Ord,  { /* fields omitted */ }

A queue which orders entrys by priority

Implementations

impl<K, P> PriorityQueue<K, P> where
    K: Send,
    P: PartialOrd + Default + Ord, 

pub fn new() -> PriorityQueue<K, P>

Create a new PriorityQueue

pub fn sync(&self, stash: &mut Stash<'_, K, P>)

Inserts all elements from the stash to the PriorityQueue, empties stash.

pub fn send(&self, entry: K, prio: P, stash: &mut Stash<'_, K, P>)

Pushes an message with prio onto the queue, uses a Stash as temporary storage when the queue is contended. Drains the stash in the uncontended case.

pub fn recv_guard(&self) -> ReceiveGuard<'_, K, P>

Returns the smallest entry from a queue. This entry is wraped in a ReceiveGuard/Message

pub fn try_recv_guard(&self) -> Option<ReceiveGuard<'_, K, P>>

Try to get the smallest entry from a queue. Will return Some when a message is available.

pub fn recv(&self) -> Message<K, P>

Returns the smallest entry from a queue.

pub fn try_recv(&self) -> Option<Message<K, P>>

Try to get the smallest entry from a queue. Will return Some when a message is available.

Trait Implementations

impl<K: Debug, P: Debug> Debug for PriorityQueue<K, P> where
    K: Send,
    P: PartialOrd + Default + Ord, 

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

Formats the value using the given formatter.

impl<K, P> Default for PriorityQueue<K, P> where
    K: Send,
    P: PartialOrd + Default + Ord, 

fn default() -> Self

Returns the “default value” for a type.