Struct SpscRingBuffer

pub struct SpscRingBuffer;

Factory for creating producer/consumer pairs.

Implementations

impl SpscRingBuffer

pub fn new<T>(capacity: usize) -> (Producer<T>, Consumer<T>)

Creates a new SPSC ring buffer with the given capacity.

The actual capacity will be rounded up to the next power of 2. Returns a (Producer, Consumer) pair for inter-thread communication.

Examples

use bbx_core::spsc::SpscRingBuffer;

let (mut producer, mut consumer) = SpscRingBuffer::new::<i32>(4);

producer.try_push(42).unwrap();
assert_eq!(consumer.try_pop(), Some(42));