awkernel_sync 0.1.0

no_std synchronization primitives (mutex, rwlock, spinlock, MCS lock) with interrupt guards for the Awkernel operating system.
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

#[cfg(loom)]
#[test]
fn model_check_mcslock() {
    use awkernel_sync::{mcs::MCSLock, mutex::MCSNode};
    use loom::{sync::Arc, thread};

    loom::model(|| {
        let lock = Arc::new(MCSLock::new(0));
        let num_threads = 2;
        let num_iterations = 2;

        let threads: Vec<_> = (0..num_threads)
            .map(|_| {
                let lock = lock.clone();
                thread::spawn(move || {
                    for _ in 0..num_iterations {
                        let mut node = MCSNode::new();
                        let mut guard = lock.lock(&mut node);
                        guard.with_mut(|data| unsafe { *data += 1 });
                    }
                })
            })
            .collect();

        for thread in threads {
            thread.join().unwrap();
        }

        let mut node = MCSNode::new();
        let data = lock.lock(&mut node).with_mut(|data| unsafe { *data });

        assert_eq!(num_threads * num_iterations, data);
    });
}