Struct SchedulerRuntime 

pub struct SchedulerRuntime { /* private fields */ }

调度器运行时

封装 sz_orm_scheduler::CronScheduler，提供 tokio 兼容的调度循环。

设计

• 不调用 CronScheduler::start()（因为它用 std::thread::spawn，会占用阻塞线程）
• 改用 tokio::time::interval + try_fire_due() 在 tokio 任务中循环
• 监听 CancellationToken 优雅退出
• 保留 CronScheduler 的所有 API（schedule/cancel/pause/resume/list_tasks/register_handler）

用法

use sz_rust_core::runtime::scheduler::{SchedulerRuntime, SchedulerRuntimeConfig};
use sz_orm_scheduler::ScheduledTask;
use tokio_util::sync::CancellationToken;

let runtime = SchedulerRuntime::new(SchedulerRuntimeConfig::default());
let task = ScheduledTask::new("task-1", "每分钟任务", "0 * * * *")
    .with_callback("demo::minute_task");
runtime.schedule(task).unwrap();

let token = CancellationToken::new();
let handle = runtime.start(token.clone());
// ... 业务运行 ...
token.cancel();
let _ = handle.await;

Implementations

impl SchedulerRuntime

pub fn new(config: SchedulerRuntimeConfig) -> Self

创建调度器运行时

pub fn start(&self, token: CancellationToken) -> JoinHandle<()>

启动调度循环（返回 JoinHandle，调用方持有）

行为

1. 每 tick_ms 毫秒调用 scheduler.try_fire_due(now) 触发到期任务
2. 监听 token.cancelled()，收到信号后停止循环
3. 不调用 CronScheduler::stop()（避免 JoinHandle::join() 阻塞）

pub fn schedule(&self, task: ScheduledTask) -> Result<(), SchedulerError>

注册调度任务（委托给 CronScheduler::schedule）

pub fn cancel(&self, task_id: &str) -> Result<(), SchedulerError>

取消任务（委托给 CronScheduler::cancel）

pub fn pause(&self, task_id: &str) -> Result<(), SchedulerError>

暂停任务（委托给 CronScheduler::pause）

pub fn resume(&self, task_id: &str) -> Result<(), SchedulerError>

恢复任务（委托给 CronScheduler::resume）

pub fn list_tasks(&self) -> Vec<ScheduledTask>

列出所有任务（委托给 CronScheduler::list_tasks）

pub fn register_handler( &self, task_id: impl Into<String>, handler: Arc<dyn JobHandler>, )

注册任务处理器（委托给 CronScheduler::register_handler）

pub fn try_fire_due(&self) -> usize

手动触发一次到期任务检查（对齐 scheduler:run 命令）

pub fn task_count(&self) -> usize

获取任务数量

pub fn config(&self) -> &SchedulerRuntimeConfig

获取配置

pub fn scheduler(&self) -> &CronScheduler

获取内部 CronScheduler 引用（用于直接调用未暴露的方法）