1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
//!
//! `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`添加如下:
//!
//! ```rust
//! [dependencies]
//! lynn_sundial = "1"
//! ```
//!
//! ```rust
//! use chrono::Local;
//! use lynn_sundial::schedule_api::*;
//! #[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
//! ......
//! */
//! ```
/// 定时任务
/// 定时任务