Struct TimerTask 

pub struct TimerTask { /* private fields */ }

定时器任务

用户通过两步式 API 使用：

1. 使用 TimerTask::new() 创建任务
2. 使用 TimerWheel::register() 或 TimerService::register() 注册任务

Implementations

impl TimerTask

pub fn new(delay: Duration, callback: Option<CallbackWrapper>) -> Self

创建新的定时器任务

参数

• delay: 延迟时间
• callback: 回调函数（可选）

示例

use kestrel_protocol_timer::TimerTask;
use std::time::Duration;
use std::sync::Arc;
 
// 创建带回调的任务
let callback = Arc::new(|| async {
    println!("Timer fired!");
});
let task = TimerTask::new(Duration::from_secs(1), Some(callback));
 
// 创建仅通知的任务
let task = TimerTask::new(Duration::from_secs(1), None);

pub fn get_id(&self) -> TaskId

获取任务 ID

示例

use kestrel_protocol_timer::TimerTask;
use std::time::Duration;
 
let task = TimerTask::new(Duration::from_secs(1), None);
let task_id = task.get_id();
println!("Task ID: {:?}", task_id);