microlock/examples/channel.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();
    }
}