Module nolock::queues::spsc::unbounded

An unbounded lock-free Queue

Example

use nolock::queues::spsc::unbounded;

// Create a new UnboundedQueue
let (mut rx, mut tx) = unbounded::queue();

// Enqueue 13
tx.enqueue(13);
// Dequeue the 13 again
assert_eq!(Ok(13), rx.try_dequeue());

Reference:

• An Efficient Unbounded Lock-Free Queue - for Multi-core Systems

Structs

AsyncUnboundedReceiver

This is the async Variant of the UnboundedReceiver.

AsyncUnboundedSender

This is the async Variant of the UnboundedSender.

DequeueFuture

The Future returned by the dequeue-Operation

UnboundedReceiver

The Receiver-Half of an unbounded Queue

UnboundedSender

The Sender-Half of an unbounded Queue

Functions

async_queue

Creates a new async SPSC-Queue and returns its respective (AsyncUnboundedReceiver, AsyncUnboundedSender)

queue

Creates a new Queue