Module spsc 

This module provides implementations of single-producer single-consumer queues.

It contains two implementations:

• [const_bounded]: A const bounded ring buffer. Use new_bounded or new_cache_padded_bounded or SPSCBoundedQueue.
• [unbounded]: An unbounded ring buffer. Use one of the new_unbounded, new_cache_padded_unbounded, new_unbounded_with_sync_cell and new_cache_padded_unbounded_with_sync_cell.

Structs

CachePaddedSPSCConsumer

The consumer of the SPSCBoundedQueue.

CachePaddedSPSCProducer

The producer of the SPSCBoundedQueue.

CachePaddedSPSCUnboundedConsumer

The consumer of the [SPSCUnboundedQueue].

CachePaddedSPSCUnboundedProducer

The producer of the [SPSCUnboundedQueue].

SPSCBoundedQueue

The single-producer, single-consumer ring-based const bounded queue.

SPSCConsumer

The consumer of the SPSCBoundedQueue.

SPSCProducer

The producer of the SPSCBoundedQueue.

SPSCUnboundedConsumer

The consumer of the [SPSCUnboundedQueue].

SPSCUnboundedProducer

The producer of the [SPSCUnboundedQueue].

Functions

new_bounded

Creates a new single-producer, single-consumer queue with the given capacity. Returns producer and consumer.

new_cache_padded_bounded

Creates a new single-producer, single-consumer queue with the given capacity. Returns producer and consumer.

new_cache_padded_unbounded

Calls new_cache_padded_unbounded_with_sync_cell with NaiveRWLock.

new_cache_padded_unbounded_with_sync_cell

Creates a new single-producer, single-consumer unbounded queue. Returns producer and consumer.

new_unbounded

Calls new_unbounded_with_sync_cell with NaiveRWLock.

new_unbounded_with_sync_cell

Creates a new single-producer, single-consumer unbounded queue. Returns producer and consumer.