Struct Cron 

pub struct Cron { /* private fields */ }

Implementations

impl Cron

pub fn list(&self) -> Vec<Job>

pub async fn add(&mut self, job: Job)

Examples found in repository

examples/main.rs (line 16)

async fn main() -> Result<()> {
    // 构建一个Cron调度器实例，开启调试模式
    let mut crond = CronBuilder::default().debug(true).build().unwrap();
    // 启动Cron调度器
    crond.run().await;

    // 创建第1个任务，每秒触发一次，执行一个简单的打印操作
    let j1 = Job::new("test", "* * * * * *", || println!("test"))?;
    crond.add(j1).await;

    // 创建第2个任务
    sleep(Duration::from_secs(3)).await;
    let j2 = Job::new("test2", "* * * * * *", || println!("test2"))?;
    crond.add(j2.clone()).await;

    // 移除第2个任务
    sleep(Duration::from_secs(3)).await;
    crond.remove(j2.id).await;

    // 按下第1次Ctrl+C停止调度器
    tokio::signal::ctrl_c().await?;
    crond.stop();

    // 按下第2次Ctrl+C信号退出进程
    tokio::signal::ctrl_c().await?;
    Ok(())
}

pub async fn remove(&mut self, id: JobId)

Examples found in repository

examples/main.rs (line 25)

async fn main() -> Result<()> {
    // 构建一个Cron调度器实例，开启调试模式
    let mut crond = CronBuilder::default().debug(true).build().unwrap();
    // 启动Cron调度器
    crond.run().await;

    // 创建第1个任务，每秒触发一次，执行一个简单的打印操作
    let j1 = Job::new("test", "* * * * * *", || println!("test"))?;
    crond.add(j1).await;

    // 创建第2个任务
    sleep(Duration::from_secs(3)).await;
    let j2 = Job::new("test2", "* * * * * *", || println!("test2"))?;
    crond.add(j2.clone()).await;

    // 移除第2个任务
    sleep(Duration::from_secs(3)).await;
    crond.remove(j2.id).await;

    // 按下第1次Ctrl+C停止调度器
    tokio::signal::ctrl_c().await?;
    crond.stop();

    // 按下第2次Ctrl+C信号退出进程
    tokio::signal::ctrl_c().await?;
    Ok(())
}

pub async fn run(&mut self)

Examples found in repository

examples/main.rs (line 12)

async fn main() -> Result<()> {
    // 构建一个Cron调度器实例，开启调试模式
    let mut crond = CronBuilder::default().debug(true).build().unwrap();
    // 启动Cron调度器
    crond.run().await;

    // 创建第1个任务，每秒触发一次，执行一个简单的打印操作
    let j1 = Job::new("test", "* * * * * *", || println!("test"))?;
    crond.add(j1).await;

    // 创建第2个任务
    sleep(Duration::from_secs(3)).await;
    let j2 = Job::new("test2", "* * * * * *", || println!("test2"))?;
    crond.add(j2.clone()).await;

    // 移除第2个任务
    sleep(Duration::from_secs(3)).await;
    crond.remove(j2.id).await;

    // 按下第1次Ctrl+C停止调度器
    tokio::signal::ctrl_c().await?;
    crond.stop();

    // 按下第2次Ctrl+C信号退出进程
    tokio::signal::ctrl_c().await?;
    Ok(())
}

pub fn stop(&mut self)

Examples found in repository

examples/main.rs (line 29)

async fn main() -> Result<()> {
    // 构建一个Cron调度器实例，开启调试模式
    let mut crond = CronBuilder::default().debug(true).build().unwrap();
    // 启动Cron调度器
    crond.run().await;

    // 创建第1个任务，每秒触发一次，执行一个简单的打印操作
    let j1 = Job::new("test", "* * * * * *", || println!("test"))?;
    crond.add(j1).await;

    // 创建第2个任务
    sleep(Duration::from_secs(3)).await;
    let j2 = Job::new("test2", "* * * * * *", || println!("test2"))?;
    crond.add(j2.clone()).await;

    // 移除第2个任务
    sleep(Duration::from_secs(3)).await;
    crond.remove(j2.id).await;

    // 按下第1次Ctrl+C停止调度器
    tokio::signal::ctrl_c().await?;
    crond.stop();

    // 按下第2次Ctrl+C信号退出进程
    tokio::signal::ctrl_c().await?;
    Ok(())
}

Trait Implementations

impl Default for Cron

fn default() -> Cron

Returns the “default value” for a type.