44 lines
1.2 KiB
Markdown
44 lines
1.2 KiB
Markdown
# microlock
|
|
|
|
Microlock is a smallish crate for waiting. It contains an UntimedLock suitable
|
|
for complex synchronization, and a TimedLock that can also function as such,
|
|
but additionally provides timer functionalities.
|
|
|
|
## Use-case:
|
|
|
|
The untimed lock can be used similarly to a channel, with added flexibility.
|
|
In this example, it simply replaces a channel, but more complex use-cases are
|
|
significantly less trivial with channels.
|
|
|
|
```rs
|
|
use std::{
|
|
collections::VecDeque,
|
|
sync::{Arc, Mutex},
|
|
thread,
|
|
};
|
|
|
|
use microlock::{Lock, TimedLock, UntimedLock};
|
|
|
|
fn main() {
|
|
static LOCK: UntimedLock = UntimedLock::locked();
|
|
let queue = Arc::new(Mutex::new(VecDeque::new()));
|
|
let queue2 = queue.clone();
|
|
thread::spawn(move || loop {
|
|
LOCK.wait_here();
|
|
println!("{}", queue2.lock().unwrap().pop_front().unwrap());
|
|
// try_lock because another unlock *could*ve happened since then
|
|
LOCK.try_lock();
|
|
});
|
|
|
|
let timer = TimedLock::unlocked();
|
|
for i in 0..5 {
|
|
timer.lock_for_ms(100);
|
|
println!("Sending {i}...");
|
|
queue.lock().unwrap().push_back(format!("Hello! {i}"));
|
|
LOCK.unlock();
|
|
println!("Sent!");
|
|
timer.wait_here();
|
|
}
|
|
}
|
|
```
|