oneringbuf 0.7.0

A lock-free single-producer, single-consumer (SPSC) ring buffer with in-place mutability, asynchronous support, and virtual memory optimisation.
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
41
42
43
44
45
46
47
48
49
50

use crate::{common_def, get_buf};
use oneringbuf::ORBIterator;

common_def!();

#[test]
pub fn prod_drop_test() {
    let mut buf = get_buf!(SharedMut);
    let (prod, _work, cons) = buf.split_mut();

    assert_eq!(cons.alive_iters(), 3);

    drop(prod);

    assert_eq!(cons.alive_iters(), 2);
}

#[test]
pub fn work_drop_test() {
    let mut buf = get_buf!(SharedMut);
    let (_prod, work, cons) = buf.split_mut();

    assert_eq!(cons.alive_iters(), 3);

    drop(work);

    assert_eq!(cons.alive_iters(), 2);
}

#[test]
pub fn cons_drop_test() {
    let mut buf = get_buf!(SharedMut);
    let (prod, _work, cons) = buf.split_mut();

    assert_eq!(prod.alive_iters(), 3);

    drop(cons);

    assert_eq!(prod.alive_iters(), 2);
}

#[test]
pub fn drop_everything() {
    let mut buf = get_buf!(SharedMut);
    let (prod, work, cons) = buf.split_mut();

    drop(prod);
    drop(work);
    drop(cons);
}