os-sync 0.3.3

Simple synchronization primitives based on OS semaphore
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

use os_sync::{Mutex, SemMutex};
use core::sync::atomic::{AtomicBool, Ordering};

#[test]
fn should_lock_sem_mutex_without_contest() {
    let mutex = SemMutex::new().unwrap();

    {
        let _lock = mutex.lock();
    }

    {
        let _lock = mutex.try_lock().unwrap();
    }
}

#[test]
fn should_lock_sem_mutex_with_contest() {
    let flag = std::sync::Arc::new(AtomicBool::new(false));
    let flag_clone = flag.clone();
    let mutex = std::sync::Arc::new(SemMutex::new().unwrap());
    let mutex_clone = mutex.clone();

    let join = std::thread::spawn(move || {
        let _lock = mutex_clone.lock();
        flag_clone.store(true, Ordering::Relaxed);
    });

    let _lock = mutex.lock();
    assert!(!flag.load(Ordering::Relaxed));
    drop(_lock);

    join.join().unwrap();
    assert!(flag.load(Ordering::Relaxed));
}