loom 0.1.0

Model checker for concurrent code
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

#![cfg(feature = "futures")]

extern crate futures;
extern crate loom;

use loom::fuzz_future;
use loom::sync::atomic::AtomicUsize;
use loom::thread;
use loom::futures::task;

use futures::{
    future::{
        lazy,
        poll_fn,
    },
    Async
};

use std::sync::Arc;
use std::sync::atomic::Ordering::Relaxed;

#[test]
fn fuzz_valid() {
    fuzz_future(|| {
        lazy(|| {
            let num = Arc::new(AtomicUsize::new(0));
            let task = task::current();

            thread::spawn({
                let num = num.clone();

                move || {
                    num.store(1, Relaxed);
                    task.notify();
                }
            });

            poll_fn(move || {
                if 1 == num.load(Relaxed) {
                    Ok(Async::Ready(()))
                } else {
                    Ok(Async::NotReady)
                }
            })
        })
    });
}