Struct RingBufferWriter 

pub struct RingBufferWriter<T, const N: usize> { /* private fields */ }

Implementations

impl<T, const N: usize> RingBufferWriter<T, N>

pub fn push(&mut self, t: T) -> Option<T>

Push an element into the RingBuffer. It returns Some(T) if the RingBuffer is full, giving back the ownership of T.

Examples found in repository

examples/throughput.rs (line 12)

fn main() {
    static COUNTER: AtomicUsize = AtomicUsize::new(0);
    let (mut tx, mut rx) = RingBuffer::<usize, 1_024>::init();

    std::thread::spawn(move || loop {
        if tx.push(1).is_some() {
            std::thread::yield_now();
        }
    });

    std::thread::spawn(move || loop {
        if rx.pull().is_some() {
            COUNTER.fetch_add(1, Ordering::Relaxed);
        } else {
            std::thread::yield_now();
        }
    });

    static STEP: Duration = Duration::from_secs(1);
    let start = Instant::now();
    for i in 1..=u32::MAX {
        std::thread::sleep(start + i * STEP - Instant::now());
        println!("{} elem/s", COUNTER.swap(0, Ordering::Relaxed));
    }
}

pub fn is_full(&mut self) -> bool

Check if the RingBuffer is full and evenutally updates the internal cached indexes.

Trait Implementations

impl<T: Send, const N: usize> Send for RingBufferWriter<T, N>

impl<T: Sync, const N: usize> Sync for RingBufferWriter<T, N>