Struct Reader

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

Read side of the triple buffer.

Implementations

impl<T> Reader<T>

pub fn read_newest(&mut self) -> &T

Get a view to the newest state currently in the buffer.

The Writer is not blocked while the returned borrow is held, but any new written data will only be visible by calling this method again.

It is possible for multiple write updates to happen while a single read is in process.

Example

let (mut writer, mut reader) = simple_triple_buffer::new_clone(0);

let guard = reader.read_newest();
assert_eq!(*guard, 0);

writer.write_new(|old, new| *new = *old + 1);
assert_eq!(*guard, 0);

let guard = reader.read_newest();
assert_eq!(*guard, 1);

Examples found in repository

examples/counter.rs (line 25)

fn main() {
    let (mut w, mut r) = new_with(State { v: 0 }, |s| {
        println!("Cloned state!");
        s.clone()
    });

    let tw = std::thread::spawn(move || loop {
        w.write_new(|last, new| {
            new.v = last.v + 1;
        });
    });

    let tr = std::thread::spawn(move || {
        let mut last = 0;
        loop {
            let state = r.read_newest();
            println!("Value: {} (+{})", state.v, state.v - last);
            last = state.v;
            std::thread::sleep(Duration::from_millis(20));
        }
    });

    tw.join().unwrap();
    tr.join().unwrap();
}