#调度器 #作业调度器 #作业 #任务调度器 #作业调度

clokwerk

一个简单的Rust重复任务调度器,类似于Python的schedule

10个版本

0.4.0 2022年11月23日
0.4.0-rc12021年5月5日
0.3.5 2021年5月5日
0.3.4 2020年12月11日
0.1.0 2018年9月7日

#119日期和时间

Download history 2774/week @ 2024-03-01 3127/week @ 2024-03-08 3115/week @ 2024-03-15 3037/week @ 2024-03-22 3052/week @ 2024-03-29 3007/week @ 2024-04-05 2924/week @ 2024-04-12 3171/week @ 2024-04-19 2938/week @ 2024-04-26 2763/week @ 2024-05-03 2479/week @ 2024-05-10 2540/week @ 2024-05-17 2632/week @ 2024-05-24 3030/week @ 2024-05-31 2866/week @ 2024-06-07 2328/week @ 2024-06-14

11,288 每月下载量
用于 19 个包 (15 直接)

Apache-2.0

77KB
1.5K SLoC

Clokwerk,一个简单的调度器

Crate API

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();

有关使用示例的更多示例,请参阅文档

类似库

依赖关系

~1–6.5MB
~27K SLoC