Supports configuration of the maximum number of parallelism of tasks.

Dynamically cancel a running task instance by means of a handle.

If you're looking for a distributed task scheduling platform, check out thedelicate

Examples

use anyhow::Result;use delay_timer::prelude::*;fnmain() ->Result<()>{// Build an DelayTimer that uses the default configuration of the Smol runtime internally.let delay_timer =DelayTimerBuilder::default().build();// Develop a print job that runs in an asynchronous cycle.// A chain of task instances.let task_instance_chain = delay_timer.insert_task(build_task_async_print()?)?;// Get the running instance of task 1.let task_instance = task_instance_chain.next_with_wait()?;// Cancel running task instances.   task_instance.cancel_with_wait()?;// Remove task which id is 1.   delay_timer.remove_task(1)?;// No new tasks are accepted; running tasks are not affected.   delay_timer.stop_delay_timer()?;Ok(())}fnbuild_task_async_print() ->Result<Task,TaskError>{letmut task_builder =TaskBuilder::default();let body = ||async{println!("create_async_fn_body!");Timer::after(Duration::from_secs(3)).await;println!("create_async_fn_body:i'success");};   task_builder.set_task_id(1).set_frequency_repeated_by_cron_str("@secondly").set_maximum_parallel_runnable_num(2).spawn_async_routine(body)}

use delay_timer::prelude::*;use anyhow::Result;use smol::Timer;use std::time::Duration;#[tokio::main]asyncfnmain() ->Result<()>{// In addition to the mixed (smol & tokio) runtime// You can also share a tokio runtime with delayTimer, please see api `DelayTimerBuilder::tokio_runtime` for details.// Build an DelayTimer that uses the default configuration of the Smol runtime internally.let delay_timer =DelayTimerBuilder::default().build();// Develop a print job that runs in an asynchronous cycle.let task_instance_chain = delay_timer.insert_task(build_task_async_print()?)?;// Get the running instance of task 1.let task_instance = task_instance_chain.next_with_async_wait().await?;// Cancel running task instances.   task_instance.cancel_with_async_wait().await?;// Remove task which id is 1.   delay_timer.remove_task(1)?;// No new tasks are accepted; running tasks are not affected.   delay_timer.stop_delay_timer()}fnbuild_task_async_print() ->Result<Task,TaskError>{letmut task_builder =TaskBuilder::default();let body = ||async{println!("create_async_fn_body!");Timer::after(Duration::from_secs(3)).await;println!("create_async_fn_body:i'success");};   task_builder.set_task_id(1).set_frequency_repeated_by_cron_str("@secondly").set_maximum_parallel_runnable_num(2).spawn_async_routine(body)}

#[macro_use]use delay_timer::prelude::*;use std::sync::atomic::{AtomicUsize,Ordering::{Acquire,Release},};use std::sync::Arc;let delay_timer =DelayTimer::new();let share_num =Arc::new(AtomicUsize::new(0));let share_num_bunshin = share_num.clone();let body =move ||{    share_num_bunshin.fetch_add(1,Release);};let task =TaskBuilder::default().set_frequency_count_down_by_cron_str(expression,3).set_task_id(1).spawn_routine(body)?;delay_timer.add_task(task)?;

#[macro_use]use delay_timer::prelude::*;use hyper::{Client,Uri};fnbuild_task_customized_async_task() ->Result<Task,TaskError>{let id =1;let name =String::from("someting");letmut task_builder =TaskBuilder::default();let body =move ||{let name_ref = name.clone();asyncmove{async_template(id, name_ref).await.expect("Request failed.");sleep(Duration::from_secs(3)).await;println!("create_async_fn_body:i'success");}};   task_builder.set_frequency_repeated_by_cron_str("0,10,15,25,50 0/1 * * Jan-Dec * 2020-2100").set_task_id(5).set_maximum_running_time(5).spawn_async_routine(body)}pubasyncfnasync_template(id:i32,name:String) ->Result<()>{let url =format!("https://httpbin.org/get?id={}&name={}", id, name);letmut res = surf::get(url).await?;dbg!(res.body_string().await?);Ok(())}

License

To Do List

Contribution