orx-concurrent-option 1.6.0

ConcurrentOption is a lock-free concurrent read and write option type.
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
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93

#![cfg(not(miri))]

use orx_concurrent_option::*;
use std::time::Duration;
use test_case::test_matrix;

#[cfg(not(miri))]
const N: usize = 100;
#[cfg(miri)]
const N: usize = 15;

#[test_matrix(
    [2, 4, 8, 16],
    [false, true]
)]
fn concurrent_get_or_insert_single_writer(num_readers: usize, do_sleep: bool) {
    let maybe = ConcurrentOption::some(7.to_string());
    let maybe_ref = &maybe;

    std::thread::scope(|s| {
        for _ in 0..(num_readers / 2) {
            s.spawn(move || reader(do_sleep, maybe_ref));
        }

        s.spawn(move || get_or_inserter(do_sleep, maybe_ref));

        for _ in 0..(num_readers / 2) {
            s.spawn(move || reader(do_sleep, maybe_ref));
        }
    });
}

#[test_matrix(
    [4, 8],
    [2, 4, 8, 16],
    [false, true]
)]
fn concurrent_get_or_insert_multiple_writer(
    num_writers: usize,
    num_readers: usize,
    do_sleep: bool,
) {
    let maybe = ConcurrentOption::some(9.to_string());
    let maybe_ref = &maybe;

    std::thread::scope(|s| {
        for _ in 0..(num_writers / 2) {
            s.spawn(move || get_or_inserter(do_sleep, maybe_ref));
        }

        for _ in 0..num_readers {
            s.spawn(move || reader(do_sleep, maybe_ref));
        }

        for _ in 0..(num_writers / 2) {
            s.spawn(move || get_or_inserter(do_sleep, maybe_ref));
        }
    });
}

// helpers
fn reader(do_sleep: bool, maybe: &ConcurrentOption<String>) {
    for _ in 0..N {
        sleep(do_sleep);

        let is_nine_or_seven = maybe
            .map(|x| x == &7.to_string() || x == &9.to_string())
            .unwrap_or(false);
        assert!(is_nine_or_seven);
    }
}

fn get_or_inserter(do_sleep: bool, maybe: &ConcurrentOption<String>) {
    for i in 0..N {
        sleep(do_sleep);
        match i % 5 {
            1 => {
                let _ = unsafe { maybe.get_or_insert(7.to_string()) };
            }
            3 => {
                let _ = unsafe { maybe.get_or_insert(9.to_string()) };
            }
            _ => {}
        }
    }
}

fn sleep(do_sleep: bool) {
    if do_sleep {
        let duration = Duration::from_millis(24);
        std::thread::sleep(duration);
    }
}