lynn_sundial

Lynn_sundial

Lynn_sundial 是一个支持cron的异步并发定时任务管理器

特点

• cron: 基于cron库，支持cron解析

• async: 基于tokio的异步任务

• reactor + actor: reactor+actor模型设计

• order/disorder task: 同时支持有序/无序的定时任务

  适用场景: Lynn_sundial采用时间轮+异步线程的设计，适用于高并发(同一时间点有多个任务需执行)、大规模(1000任务以上)，以O(1)复杂度实现高性能调度，但需容忍预分配内存的轻微浪费

如何使用

Dependencies

default features

default features包含：schedule

使用 cargo add lynn_sundial 或者在Cargo.toml添加如下:

[dependencies]
lynn_sundial = "1"

use chrono::Local;
use lynn_sundial::schedule_api::*;

mod schedule;
#[tokio::main]
async fn main() {
    let mut scheduler = Scheduler::new();
    for _ in 0..3 {
        // 新增有序定时任务
        let _ = scheduler.push_task(
            "0/1 * * * * ?",
            order_println_second_time,
            RepeatModel::Repetition,
        );
        // 新增无序定时任务
        let _ = scheduler.push_disorder_task(
            "0/1 * * * * ?",
            disorder_println_second_time,
            RepeatModel::Repetition,
        );
    }
    for _ in 0..3 {
        // 新增有序定时任务
        let _ = scheduler.push_task(
            "0 0/1 * * * ?",
            order_println_minute_time,
            RepeatModel::Repetition,
        );
        // 新增无序定时任务
        let _ = scheduler.push_disorder_task(
            "0 0/1 * * * ?",
            disorder_println_minute_time,
            RepeatModel::Repetition,
        );
    }
    scheduler.wait_all().await
}

async fn order_println_second_time() {
    let now_time = Local::now();
    println!("order task - second -> {}", now_time);
}

async fn disorder_println_second_time() {
    let now_time = Local::now();
    println!("disorder task - second -> {}", now_time);
}

async fn order_println_minute_time() {
    let now_time = Local::now();
    println!("order task - minute -> {}", now_time);
}

async fn disorder_println_minute_time() {
    let now_time = Local::now();
    println!("disorder task - minute -> {}", now_time);
}

/*
......
order task - second -> 2025-08-20 11:39:59.037835362 +08:00
order task - second -> 2025-08-20 11:39:59.037866764 +08:00
order task - second -> 2025-08-20 11:39:59.037888082 +08:00
disorder task - second -> 2025-08-20 11:39:59.045977090 +08:00
disorder task - second -> 2025-08-20 11:39:59.046011978 +08:00
disorder task - second -> 2025-08-20 11:39:59.046027488 +08:00
......
order task - minute -> 2025-08-20 11:40:00.243358355 +08:00
order task - minute -> 2025-08-20 11:40:00.243398461 +08:00
order task - minute -> 2025-08-20 11:40:00.243417066 +08:00
disorder task - minute -> 2025-08-20 11:40:00.247555345 +08:00
disorder task - minute -> 2025-08-20 11:40:00.247583417 +08:00
disorder task - minute -> 2025-08-20 11:40:00.247586003 +08:00
......
*/

路线

核心功能

✅ 解析cron的定时异步任务

✅ 有序任务

✅ 无序任务

扩展功能

• 可自定义任务的函数参数

Note:

如果没有明确标识功能在什么版本中开始支持，说明功能还在开发中

版本日志

version.md

License

MIT license

贡献

除非您另有明确说明，否则您有意提交以包含在Lynn_sundial中的任何贡献都应被许可为MIT，无需任何额外的条款或条件。