Struct Consumer 

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

Consumer handle. Move it to the consuming thread.

Implementations

impl<T> Consumer<T>

pub fn try_pop(&mut self) -> Option<T>

Pop a value. Returns None if the buffer is empty. Wait-free.

Examples found in repository

examples/demo.rs (line 16)

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).

Trait Implementations

impl<T: Send> Send for Consumer<T>