lunatic 0.14.1

Helper library for building Rust applications that run on lunatic.
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

use std::cell::{Cell, RefCell};

use lunatic::{process_local, spawn_link};
use lunatic_test::test;

#[test]
fn two_processes_have_independent_locals() {
    process_local!(static FOO: RefCell<u32> = RefCell::new(1));

    FOO.with_borrow_mut(|mut f| {
        *f = 2;
    });

    // each process starts out with the initial value of 1
    let child = spawn_link!(@task || {
        FOO.with_borrow_mut(|mut f| {
            assert_eq!(*f, 1);
            *f = 3;
        });
    });

    // wait for the process to complete
    let _ = child.result();

    // we retain our original value of 2 despite the child process
    FOO.with_borrow(|f| {
        assert_eq!(*f, 2);
    });
}

#[test]
fn cell_set_get() {
    process_local! {
        static X: Cell<i32> = panic!("!");
    }
    // Calling X.get() here would result in a panic.
    X.set(123); // But X.set() is fine, as it skips the initializer above.
    assert_eq!(X.get(), 123);
}

#[test]
fn cell_replace() {
    process_local! {
        static X: Cell<i32> = Cell::new(1);
    }

    assert_eq!(X.replace(2), 1);
    assert_eq!(X.replace(3), 2);
}

#[test]
fn refcell_borrow() {
    process_local! {
        static X: RefCell<Vec<i32>> = RefCell::new(Vec::new());
    }

    X.with_borrow(|v| assert!(v.is_empty()));
}

#[test]
fn refcell_take() {
    process_local! {
        static X: RefCell<Vec<i32>> = RefCell::new(Vec::new());
    }

    X.with_borrow_mut(|mut v| v.push(1));
    let a = X.take();
    assert_eq!(a, vec![1]);
    X.with_borrow(|v| assert!(v.is_empty()));
}