thread-locker 0.1.0

Thread locker library for Rust
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

mod tests;

use std::sync::{Arc, Condvar, Mutex};

#[derive(Debug, Clone)]
pub struct Locker(Arc<(Mutex<bool>, Condvar)>);

impl Locker {
    pub fn wait(self) {
        let pair = self.0;
        let &(ref lock, ref cvar) = &*pair;
        let mut started = lock.lock().unwrap();
        while !*started {
            started = cvar.wait(started).unwrap();
        }
    }
    pub fn unlock(self) {
        let pair = self.0;
        let &(ref lock, ref cvar) = &*pair;
        let mut started = lock.lock().unwrap();
        *started = true;
        cvar.notify_one();
    }
    pub fn new() -> Self {
        Locker(Arc::new((Mutex::new(false), Condvar::new())))
    }
}