Module nolock::queues::mpmc::bounded::scq

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

Example:

// Create the Queue
let (rx, tx) = scq::queue::<u64>(10);

// Insert an Item into the Queue
assert_eq!(Ok(()), tx.try_enqueue(10));
// Dequeue the previously inserted Item
assert_eq!(Ok(10), rx.try_dequeue());

Structs

Receiver

The receiving Half for a SCQ based MPMC-Queue

Sender

The sending Half for a SCQ based MPMC-Queue

Functions

queue

Creates a new Queue with the given Capacity.