qutex 0.2.6

Synchronization mechanisms that rely on lock-free and other non-(thread)blocking techniques, such as Rust futures, to guarantee mutually exclusive or shared exclusive access to data.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use crate::*;
use futures::sync::oneshot::Canceled;
use futures03::compat::Future01CompatExt;

impl<T> Qutex<T> {
    pub async fn lock_async(self) -> Result<Guard<T>, Canceled> {
        self.lock().compat().await
    }
}

impl<T> QrwLock<T> {
    pub async fn write_async(self) -> Result<WriteGuard<T>, Canceled> {
        self.write().compat().await
    }

    pub async fn read_async(self) -> Result<ReadGuard<T>, Canceled> {
        self.read().compat().await
    }
}