Module nolock::queues::mpsc::jiffy

The implemenation of a Lock-Free, possibly Wait-Free, unbounded MPSC Queue

Examples:

use nolock::queues::mpsc::jiffy;

// Create a new Queue
let (mut rx, tx) = jiffy::queue();

// Enqueue some Data
tx.enqueue(13);

// Dequeue the Data again
assert_eq!(Ok(13), rx.try_dequeue());

Reference:

• Jiffy: A Fast, Memory Efficient, Wait-Free Multi-Producers Single-Consumer Queue

Structs

AsyncReceiver

This is the asynchronous Version of the Jiffy-Receiver

AsyncSender

This is the asynchronous Version of the Jiffy-Sender

DequeueFuture

This is the Future returend by the Dequeue operation on the AsyncReceiver

OwnedIter

Iterator for all Elements from the Queue

Receiver

The Single Receiver of a Jiffy-Queue, created by calling queue

RefIter

Iterator for all Elements from the Queue

Sender

One of the Sender, created by calling queue

Functions

async_queue

Creates an async Jiffy-Queue Pair of (AsyncReceiver, AsyncSender)

queue

Creates a new empty Queue and returns their (Receiver, Sender)