#tokio #set-timeout #interval #timeout #set-interval

tokio_interval

基于Tokio实现了setInterval(callback, ms) 和 setTimeout(callback, ms) 类似于Javascript的API

2次发布

0.1.4 2023年2月21日
0.1.3 2023年2月21日
0.1.2 2023年2月21日
0.1.1 2023年2月21日
0.1.0 2023年2月21日

#895 in 异步

每月下载36

MIT许可协议

25KB
411

托克顿-间隔

基于 tokio 实现了类似于 jssetIntervalsetTimeout 的功能

目前提供了以下几个宏

  • set_interval!(cb, ms) 创建一个定时器,支持传入一个闭包
  • set_interval_async!(|| future, ms) 创建一个定时器,支持传入一个返回future回调
  • set_timeout!(cb, ms) 创建一个延时器,支持传入一个闭包
  • set_timeout_async!(future, ms) 创建一个延时器,支持传入一个future
  • clear_timer!(timer_id) 清除定时器
  • clear_all_timer!() 清除由 tokio_interval 创建的所有定时器,包含 set_interval!、set_timeout!、set_interval_async!、set_timeout_async!

注意

  • 由于实现的逻辑,set_interval 受传入的 fn 运行时耗的影响,ms 不是一个固定的间隔

使用方法

Cargo.toml

[dependencies]
tokio_interval = "<latest-version>"

main.rs

use tokio::time::{sleep,Duration};
use tokio_interval::{set_interval, set_timeout, clear_timer};

#[tokio::main]
async fn main() {
    set_timeout!(|| println!("timeout"), 500);
    set_interval!(|| println!("interval"), 500);
    // 保存id,以便手动删除
    let id = set_interval!(|| println!("clear_interval"), 500);
    sleep(Duration::from_millis(600)).await;
    // 删除定时器
    clear_interval(id);
    // 保证定时器可以继续执行
    sleep(Duration::from_millis(1200)).await;
}

依赖项

~2–3MB
~49K SLoC