mt.rs

use futures::StreamExt;
use std::{
    thread::{self},
    time::Duration,
};

async fn do_work(idx: u32) {
    thread::sleep(Duration::from_millis(500));
    dbg!(idx);
}

fn main() {
    let runtime = tokio::runtime::Builder::new_multi_thread()
        .worker_threads(5)
        .thread_name("multithreaded-runtime")
        .build()
        .unwrap();

    {
        runtime.block_on(async {
            futures::stream::iter((0..100).into_iter().map(|num| tokio::spawn(do_work(num))))
                .buffer_unordered(10)
                .collect::<Vec<_>>()
                .await;
        });
    }

    println!("Done!");
}