delay-timer - GitLite

KO | EN

gitlite — search

#react #ai #typescript #golang #rust #deep-learning #linux #macos #awesome #vue #security #ios #openai #open-source

delay-timer

(★ 329)

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

파일 탐색기

최종 버전 다운로드 (.zip)

- - bug_report.md
  - feature_request.md
- - rust.yml
- body.rs
- build.rs
- cycle_tokio_task.rs
- demo.rs
- demo_async_std.rs
- demo_async_std_and_tracing.rs
- demo_async_tokio.rs
- dynamic_cancel.rs
- generic.rs
- increase.rs
- profile_memory.rs
- share_tokio_runtime.rs
- try_spawn.php
- - feature_cfg.rs
  - mod.rs
- - event_handle.rs
  - mod.rs
  - slot.rs
  - task.rs
  - timer_core.rs
- - convenience.rs
  - mod.rs
  - parse.rs
  - status_report.rs
- entity.rs
- error.rs
- lib.rs
- prelude.rs
- DelayTImer.png
- simulation.rs
.gitignore
Cargo.toml
CHANGELOG.md
CODE_OF_CONDUCT.md
LICENSE-APACHE
LICENSE-MIT
README.md

# 설치 가이드

1. 코드 내려받기

git clone https://github.com/BinChengZhao/delay-timer

깃허브에서 프로젝트 코드 전체를 내 컴퓨터로 내려받습니다.

cd delay-timer

방금 내려받은 프로젝트 폴더 안으로 이동합니다.

2. Rust

보통 추천

사전 준비물

Git GitHub에서 프로젝트 코드를 내려받으려면 필요합니다.
Rust (rustup) rustup으로 설치하면 cargo도 함께 설치됩니다.

cargo build --release

Rust 프로젝트를 컴파일합니다.

cargo run

빌드 후 바로 실행까지 진행합니다.

✅ cargo build가 에러 없이 끝나면 성공입니다. target/ 폴더에 실행 파일이 생성됩니다.

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

# delay-timer  
[![Build](https://github.com/BinChengZhao/delay-timer/workflows/Build%20and%20test/badge.svg)](https://github.com/BinChengZhao/delay-timer/actions)
[![License](https://img.shields.io/badge/license-MIT%2FApache--2.0-blue.svg)](https://github.com/BinChengZhao/delay-timer)
[![Cargo](https://img.shields.io/crates/v/delay_timer.svg)](https://crates.io/crates/delay_timer)
[![Documentation](https://docs.rs/delay_timer/badge.svg)](https://docs.rs/delay_timer)

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.56**.

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](https://github.com/BinChengZhao/delay-timer/blob/master/structural_drawing/DelayTImer.png)

### If you're looking for a distributed task scheduling platform, check out the [delicate](https://github.com/BinChengZhao/delicate)

## 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 build_task_async_print() -> Result<Task, TaskError> {
    let mut 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 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 build_task_async_print() -> Result<Task, TaskError> {
    let mut 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)
}

```

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

``` rust
 #[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)?;

```

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

fn build_task_customized_async_task() -> Result<Task, TaskError> {
    let id = 1;
    let name = String::from("someting");
    let mut task_builder = TaskBuilder::default();

let body = move || {
        let name_ref = name.clone();
        async move {
            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)
}

pub async fn async_template(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.body_string().await?);

Ok(())
}

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

## License

Licensed under either of

* MIT license ([LICENSE-MIT](LICENSE-MIT) or http://opensource.org/licenses/MIT)

## To Do List
- [x] Support tokio Ecology.
- [x] Disable unwrap related methods that will panic.
- [ ] Thread and running task quit when delayTimer drop.
- [ ] neaten todo in code, replenish tests and benchmark.
- [ ] batch-opration.
- [x] report-for-server.
- [ ] Future upgrade of delay_timer to multi-wheel mode, different excutor handling different wheels e.g. subtract laps for one wheel, run task for one wheel.

#### 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.