#计时器 #tokio #异步-I/O

async-timers

提供异步定时器原语

4 个版本

0.1.4 2022年8月21日
0.1.3 2022年8月21日
0.1.2 2022年8月21日
0.1.1 2022年8月20日
0.1.0 2022年8月19日

#927 in 异步

Unlicense 许可

16KB
204 代码行

异步计时器

Crates.io Unlicensed Documentation Build Status codecov LoC

此软件包提供 PeriodicTimerOneshotTimer 以在 async 上下文(tokio)中使用。

使用方法

示例

use async_timers::{OneshotTimer, PeriodicTimer};
use tokio::time::Duration;

#[tokio::main]
async fn main() {
    let mut start_delay = OneshotTimer::expired();
    let mut stop_delay = OneshotTimer::expired();
    let mut periodic = PeriodicTimer::stopped();

    let mut exit_loop_delay = OneshotTimer::scheduled(Duration::from_secs(10));

    // The following call will block forever
    // start_delay.tick().await;

    // Useful in event loop in select! blocks

    start_delay.schedule(Duration::from_secs(2));
    println!("Periodic timer will start in 2 sec");

    loop {
        tokio::select! {
            _ = start_delay.tick() => {
                // Start periodic timer with period of 500 ms
                periodic.start(Duration::from_millis(500));

                stop_delay.schedule(Duration::from_secs(3));
                println!("Periodic timer will stop in 3 sec");
            }
            _ = stop_delay.tick() => {
                // Stop periodic timer
                periodic.stop();
                exit_loop_delay.schedule(Duration::from_secs(3));
                println!("Periodic timer stopped. Will exit in 3 sec");
            }
            _ = periodic.tick() => {
                println!("Periodic tick!");
            }
            _ = exit_loop_delay.tick() => {
                println!("Bye!");
                break;
            }
        }
    }
}

依赖关系

~2.6–4MB
~61K SLoC