Function magnetic::mpmc::mpmc_queue

pub fn mpmc_queue<T, B: Buffer<T>>(
    buf: B
) -> (MPMCProducer<T, B>, MPMCConsumer<T, B>)

Creates a new MPMC queue

Examples

use magnetic::mpmc::mpmc_queue;
use magnetic::buffer::dynamic::DynamicBuffer;
use magnetic::{Producer, Consumer};

let (p, c) = mpmc_queue(DynamicBuffer::new(32).unwrap());

p.push(1).unwrap();
assert_eq!(c.pop(), Ok(1));