Module nolock::queues::mpmc::bounded

This contains the Collection of bounded-MPMC-Queues proposed in the Paper, however you should basically always use scq over ncq as it scales better and in general is the intended implementation.

Example

// Creates a new Queue with the Capacity for 10 Elements
let (rx, tx) = bounded::scq::queue::<u64>(10);

// Insert a new Element into the Queue
assert_eq!(Ok(()), tx.try_enqueue(123));
// Dequeue the Element again
assert_eq!(Ok(123), rx.try_dequeue());

Modules

ncq

This Queue uses the Naive-Circular-Queue implementation provided in the Paper.

scq

This Queue uses the Scalable-Circular-Queue implementation provided in the Paper.