atomx 0.2.10

Thread safe data structures based on atomic data types.
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

#![cfg(loom)]

use atomx::signal;
use atomx::signal::sync::State;
use loom::thread;

#[test]
fn loom_signal_ack(){
    loom::model(|| {
        let (mut sender, sink1) = signal::sync::create::<f32>();
        let sink2 = sender.sink();
        let sink3 = sender.sink();
        let input1 = 0.1;
        let input2 = 0.2;
        sender.send(&input1);
        assert_eq!(State::Receiving, sender.send(&input2));

        // clock generator module
        let t1 = thread::spawn( move ||{
            assert_eq!(input1, sink1.receive());
        });

        // clock consumer module
        let t2 = thread::spawn( move || {
            assert_eq!(input1, sink2.receive());
        });

        t1.join().expect("completion");
        t2.join().expect("completion");
        assert_eq!(State::Receiving, sender.send(&input2));

        sink3.receive();
        assert_eq!(State::Ready, sender.send(&input2));

        drop(sink3);
        assert_eq!(State::AllGone, sender.send(&input2));
    });
}