Rust调度器开发：异步执行任务遇生命周期错误求助

错误原因 #

你遇到的核心问题是线程捕获的引用生命周期不满足要求：thread::spawn创建的线程可能在当前函数执行结束后继续运行，但job是should_run函数的局部引用，生命周期仅局限于函数体内。Rust的安全机制禁止这种引用"逃逸"到函数外部，否则会导致悬垂引用风险，因此抛出了'1 must outlive 'static的错误。

解决方案 #

要实现后台任务的异步执行，需要让线程持有拥有所有权的任务对象，而非临时引用。这里可以使用Arc（原子引用计数指针）来安全地跨线程共享只读任务：

1. 导入Arc模块

use std::sync::Arc;

2. 修改Job结构体的task字段类型
   将原本的Box替换为Arc，并添加'static约束（线程要求捕获的变量生命周期至少为'static）：

struct Job {
    id: i32,
    name: String,
    every: u64,
    unit: Unit,
    task: Arc<dyn Fn() -> () + Send + Sync + 'static>,
    registered_at: SystemTime
}

3. 简化add_job方法
   无需重复包装任务对象，直接将传入的Job存入向量：

fn add_job(&mut self, job: Job) {
    self.jobs.push(job);
}

4. 调整should_run方法避免引用逃逸
   克隆Arc获取任务的所有权副本，再移动到线程闭包中：

fn should_run(job: &Job) {
    match job.registered_at.elapsed() {
        Ok(elapsed) => {
            if elapsed.as_secs() % job.every == 0 {
                let task = Arc::clone(&job.task);
                thread::spawn(move || {
                    task()
                });
            }
        }
        Err(e) => {
            println!("Error: {e:?}");
        }
    };
}

5. 更新main函数中的任务创建
   用Arc::new替代Box::new来包装任务闭包：

sch.add_job(Job { 
    id: 1,
    name: String::from("downloading report"),
    every: 1,
    unit: Unit::Seconds,
    task: Arc::new(|| {
        println!("downloading...");
    }),
    registered_at: SystemTime::now()
});

额外优化提示 #

原start方法的循环逻辑存在小问题：每次遍历jobs前sleep1秒，会导致多任务场景下实际执行间隔被拉长。可以改为遍历完所有job后再sleep，或者使用tokio等异步运行时来实现更精准的定时调度。

内容的提问来源于stack exchange，提问作者Pramesti Hatta K