delay-timer

Build License Cargo Documentation

Time-manager of delayed tasks. Like crontab, but synchronous asynchronous tasks are possible, and dynamic add/cancel/remove is supported.

delay-timer is a task manager based on a time wheel algorithm, which makes it easy to manage timed tasks, or to periodically execute arbitrary tasks such as closures.

The underlying runtime is based on the optional smol and tokio, and you can build your application with either one.

The minimum-supported version of rustc is 1.49.

Except for the simple execution in a few seconds, you can also specify a specific date, such as Sunday at 4am to execute a backup task.

Supports configuration of the maximum number of parallelism of tasks.
Dynamically cancel a running task instance by means of a handle.

image

Examples

```rust

use anyhow::Result; use delay_timer::prelude::*;

fn main() -> 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(())

}

fn buildtaskasyncprint() -> Task { let mut taskbuilder = TaskBuilder::default();

let body = create_async_fn_body!({
    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_by_candy(CandyFrequency::Repeated(CandyCron::Secondly))
    .set_maximun_parallel_runable_num(2)
    .spawn(body)
    .unwrap()

}

```

Use in asynchronous contexts. ``` rust

use delay_timer::prelude::*;

use anyhow::Result;

use smol::Timer; use std::time::Duration;

[tokio::main]

async fn main() -> 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()

}

fn buildtaskasyncprint() -> Task { let mut taskbuilder = TaskBuilder::default();

let body = create_async_fn_body!({
    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(Frequency::Repeated("*/6 * * * * * *"))
    .set_maximun_parallel_runable_num(2)
    .spawn(body)
    .unwrap()

}

```

Capture the specified environment information and build the closure & task:

``` rust #[macrouse] use delaytimer::prelude::*;

use std::sync::atomic::{ AtomicUsize, Ordering::{Acquire, Release}, }; use std::sync::Arc;

let delay_timer = DelayTimer::new();

let sharenum = Arc::new(AtomicUsize::new(0)); let sharenumbunshin = sharenum.clone();

let body = createasyncfnbody!((sharenumbunshin){ sharenumbunshinref.fetch_add(1, Release); });

let task = TaskBuilder::default() .setfrequencybycandy(CandyFrequency::CountDown(9, CandyCron::Secondly)) .settaskid(1) .setmaximunparallelrunable_num(3) .spawn(body) .unwrap();

delaytimer.addtask(task);

```

Building customized-dynamic future tasks: ``` rust #[macrouse] use delaytimer::prelude::*; use hyper::{Client, Uri};

fn buildtaskcustomizedasynctask() -> Task { let mut task_builder = TaskBuilder::default();

let body = generate_closure_template("delay_timer is easy to use. .".into());
task_builder
    .set_frequency_by_candy(CandyFrequency::Repeated(AuspiciousTime::LoveTime))
    .set_task_id(5)
    .set_maximum_running_time(5)
    .spawn(body)
    .unwrap()

}

pub fn generateclosuretemplate( name: String, ) -> impl Fn(TaskContext) -> Box + 'static + Send + Sync { move |context| { let futureinner = asynctemplate(get_timestamp() as i32, name.clone());

    let future = async move {
        future_inner.await;
        context.finishe_task().await;
    };
    create_delay_task_handler(async_spawn(future))
}

}

pub async fn asynctemplate(id: i32, name: String) -> Result<()> { let url = format!("https://httpbin.org/get?id={}&name={}", id, name); let mut res = surf::get(url).await?; dbg!(res.bodystring().await?);

Ok(())

}

enum AuspiciousTime { PerSevenSeconds, PerEightSeconds, LoveTime, }

impl Into for AuspiciousTime { fn into(self) -> CandyCronStr { match self { Self::PerSevenSeconds => CandyCronStr("0/7 * * * * * *".tostring()), Self::PerEightSeconds => CandyCronStr("0/8 * * * * * *".tostring()), Self::LoveTime => CandyCronStr("0,10,15,25,50 0/1 * * Jan-Dec * 2020-2100".to_string()), } } } ```

There's a lot more in the [examples] directory.

License

Licensed under either of

To Do List

Contribution

Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in the work by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.

The author comments:

Make an upgrade plan for smooth updates in the future, Such as stop serve back-up unfinished task then up new version serve load task.bak, Runing.