sling 0.2.0

Sequentially lockign (SeqLock) Ring Buffer
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

#![allow(dead_code)]
use sling::RingBuffer;

const BUF_LEN: usize = 2_usize.pow(7);
const PAYLOAD: [u8; 8] = [0, 0, 0, 0, 0, 0, 0, 0];
const THREADS: [usize; 3] = [1, 2, 4];
const ELEMENTS: usize = 10;

fn push_pop_sling(t: usize) {
    let queue = RingBuffer::<_, BUF_LEN>::new();
    let mut writer = queue.try_lock().unwrap();
    let reader = queue.reader();

    std::thread::scope(|s| {
        let reader = &reader;
        for _ in 0..t {
            s.spawn(move || loop {
                while reader.pop_front().is_some() {}

                std::thread::yield_now();

                if reader.pop_front().is_none() {
                    break;
                }
            });
        }

        for _ in 0..ELEMENTS {
            writer.push_back(PAYLOAD);
            std::thread::yield_now();
        }
    });
}

// #[test]
fn loom() {
    loom::model(|| {
        THREADS.iter().for_each(|&t| push_pop_sling(t));
    })
}