[go: up one dir, main page]

loom 0.3.6

Permutation testing 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

use _futures::executor;
use rt::{self, ThreadHandle};

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

pub struct Notify {
    thread: ThreadHandle,
    flag: AtomicBool,
}

impl Notify {
    pub fn new() -> Notify {
        Notify {
            thread: ThreadHandle::current(),
            flag: AtomicBool::new(false),
        }
    }

    pub fn consume_notify(&self) -> bool {
        self.flag.swap(false, Relaxed)
    }
}

impl executor::Notify for Notify {
    fn notify(&self, _id: usize) {
        rt::branch();

        self.flag.store(true, Relaxed);
        self.thread.unpark();
    }
}