Module nolock::queues::spsc::unbounded [−][src]
Expand description
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:
Structs
This is the async Variant of the UnboundedReceiver
.
This is the async Variant of the UnboundedSender
.
The Future returned by the
dequeue
-Operation
The Receiver-Half of an unbounded Queue
The Sender-Half of an unbounded Queue
Functions
Creates a new async SPSC-Queue and returns its respective
(AsyncUnboundedReceiver
, AsyncUnboundedSender
)
Creates a new Queue