Struct Producer 

pub struct Producer<T> { /* private fields */ }

Producer handle. Move it to the producing thread; the type system enforces the SPSC invariant.

Implementations

impl<T> Producer<T>

pub fn try_push(&mut self, value: T) -> Result<(), T>

Push a value. Returns the input back as Err(value) if the buffer is full. Wait-free: at most one atomic load + one atomic store.

Examples found in repository

examples/demo.rs (line 9)

fn main() {
    let (mut tx, mut rx) = SpscRingBuffer::with_capacity::<u32>(16);

    let producer = thread::spawn(move || {
        for i in 0..10u32 {
            while tx.try_push(i).is_err() {}
        }
    });

    let consumer = thread::spawn(move || {
        let mut seen = Vec::new();
        while seen.len() < 10 {
            if let Some(v) = rx.try_pop() {
                seen.push(v);
            }
        }
        seen
    });

    producer.join().unwrap();
    let seen = consumer.join().unwrap();
    println!("consumed: {seen:?}");
}

pub fn capacity(&self) -> usize

Total slot count (power of two; not the requested capacity).

Trait Implementations

impl<T: Send> Send for Producer<T>