set_timeout 0.1.4

A crate which allows efficiently executing futures after some delay has passed
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33

use std::{
    sync::Arc,
    time::{Duration, Instant},
};

use rand::Rng;
use set_timeout::TimeoutScheduler;

#[tokio::main]
async fn main() {
    // wrap the scheduler in an `Arc` so that we can share it between multiple tasks.
    let scheduler = Arc::new(TimeoutScheduler::new(None));

    for _ in 0..10 {
        // spawn new tasks to show how the scheduler can be shared between multiple tasks.
        let scheduler = Arc::clone(&scheduler);
        tokio::spawn(async move {
            let start = Instant::now();
            let delay = Duration::from_millis(rand::thread_rng().gen_range(100..=1000));
            scheduler.set_timeout(delay, async move {
                println!(
                    "desired delay: {:?}, actual delay: {:?}",
                    delay,
                    start.elapsed()
                );
            })
        });
    }

    // make sure that the main task doesn't end before the timeout is executed, because if the main
    // task returns the runtime stops running.
    tokio::time::sleep(Duration::from_secs(2)).await;
}