aligned-task-scheduler 0.1.0

A scheduler that runs tasks at exact minute intervals with an optional offset, ensuring tasks are aligned to precise time boundaries.
Documentation
1
2
3
4
5
6
7
8
9
10
11
12
13
14
use std::time::SystemTime;
use tokio::time::sleep;
use std::time::Duration;
use aligned_task_scheduler::AlignedTaskScheduler;

#[tokio::main]
async fn main() {
    let scheduler = AlignedTaskScheduler::new(1, 10); // 每1分钟整点 +10秒时执行任务
    scheduler.run(|ts| async move {
        println!("执行任务的整分时间戳: {}", ts);
        println!("当前真实时间: {:?}", SystemTime::now());
        // 在这里执行你的实际逻辑,比如拉取数据、写入数据库等
    }).await;
}