10个版本
0.4.0 | 2022年11月23日 |
---|---|
0.4.0-rc1 | 2021年5月5日 |
0.3.5 | 2021年5月5日 |
0.3.4 | 2020年12月11日 |
0.1.0 | 2018年9月7日 |
#119 在 日期和时间
11,288 每月下载量
用于 19 个包 (15 直接)
77KB
1.5K SLoC
Clokwerk,一个简单的调度器
Clokwerk是一个简单的调度器,受Python的Schedule和Ruby的clockwork启发。它使用类似的DSL进行调度,而不是解析cron字符串。
默认情况下,时间和日期相对于本地时区,但可以使用Scheduler::with_tz
构造函数将其设置为不同的时区。
从版本0.4开始,Clokwerk还支持单独的AsyncScheduler
,可以轻松并发运行异步任务。
用法
// Scheduler, and trait for .seconds(), .minutes(), etc.
use clokwerk::{Scheduler, TimeUnits};
// Import week days and WeekDay
use clokwerk::Interval::*;
use std::thread;
use std::time::Duration;
// Create a new scheduler
let mut scheduler = Scheduler::new();
// or a scheduler with a given timezone
let mut scheduler = Scheduler::with_tz(chrono::Utc);
// Add some tasks to it
scheduler.every(10.minutes()).plus(30.seconds()).run(|| println!("Periodic task"));
scheduler.every(1.day()).at("3:20 pm").run(|| println!("Daily task"));
scheduler.every(Tuesday).at("14:20:17").and_every(Thursday).at("15:00").run(|| println!("Biweekly task"));
// Manually run the scheduler in an event loop
for _ in 1..10 {
scheduler.run_pending();
thread::sleep(Duration::from_millis(10));
}
// Or run it in a background thread
let thread_handle = scheduler.watch_thread(Duration::from_millis(100));
// The scheduler stops when `thread_handle` is dropped, or `stop` is called
thread_handle.stop();
有关使用示例的更多示例,请参阅文档。
类似库
- schedule-rs和job_scheduler是另外两个Rust调度库。两者都使用
cron
语法进行调度。
依赖关系
~1–6.5MB
~27K SLoC