2 unstable releases
0.2.4 | Nov 13, 2019 |
---|---|
0.0.0 | Nov 13, 2019 |
#1156 in Concurrency
52KB
1K
SLoC
Qutex
Non-thread-blocking queue-backed data locks based on Rust futures.
Includes futures capable versions of Mutex
and RwLock
.
Documentation
Example
Cargo.toml
:
[dependencies]
qutex = "0.2"
main.rs
:
extern crate qutex;
extern crate futures;
use std::thread;
use futures::Future;
use qutex::Qutex;
fn main() {
let thread_count = 100;
let mut threads = Vec::with_capacity(thread_count);
let start_val = 0;
let qutex = Qutex::new(start_val);
for _ in 0..thread_count {
let future_val = qutex.clone().lock();
let future_add = future_val.map(|mut val| {
*val += 1;
});
threads.push(thread::spawn(|| {
future_add.wait().unwrap();
}));
}
for thread in threads {
thread.join().unwrap();
}
let val = qutex.lock().wait().unwrap();
assert_eq!(*val, start_val + thread_count);
println!("Qutex final value: {}", *val);
}
Dependencies
~440–590KB