blocking_mpsc

Function blocking_mpsc 

Source
pub fn blocking_mpsc<T, const P: usize, const NUM_SEGS_P2: usize>() -> (BlockingMpscSender<T, P, NUM_SEGS_P2>, BlockingMpscReceiver<T, P, NUM_SEGS_P2>)
Expand description

Creates a default blocking MPSC queue.

Both senders and receiver use blocking operations that park threads.