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

UnboundedReceiver

The Receiver-Half of an unbounded Queue

UnboundedSender

The Sender-Half of an unbounded Queue

Functions

queue

Creates a new Queue