Sketch of queue

ordered_queue_test.rs

use std::time::Duration;
use rand::Rng;

fn main() {
    let (s, mut r) = ordered_channel::bounded(10);
    for i in 0..100 {
        let s_clone = s.clone();
        rayon::spawn_fifo(move || {
            let mut rng = rand::thread_rng();
            let sleep_time = rng.gen_range(0..100);
            std::thread::sleep(Duration::from_millis(sleep_time));
            _ = s_clone.send(i, i);
        });
        std::thread::sleep(Duration::from_millis(10));
        while let Ok(answer) = r.try_recv() {
            println!("got answer {answer}");
        }
    }
    drop(s);
    println!("done spawning");
    while let Ok(answer) = r.recv() {
        println!("got answer {answer}");
    }
}