⏱️ An asynchronous task scheduling library written in Rust
⏱️ An asynchronous task scheduling library written in Rust
About
tasklet is a task scheduling library written in Rust. It is built over tokio runtime and utilizes green threads in order to run tasks asynchronously.
Dependencies
| library | version | |-----------|---------| | cron | 0.15.0 | | chrono | 0.4.42 | | log | 0.4.29 | | tokio | 1.48.0 | | futures | 0.3.31 | | thiserror | 2.0.17 |
How to use this library
In your Cargo.toml add:
[dependencies]
tasklet = "0.2.12"
Example
Find more examples in the examples folder.
use log::info;
use simple_logger::SimpleLogger;
use tasklet::task::TaskStepStatusErr::Error;
use tasklet::task::TaskStepStatusOk::Success;
use tasklet::{TaskBuilder, TaskScheduler};
/// A simple example of a task with two steps, /// that might work or fail sometimes. #[tokio::main] async fn main() { // Init the logger. SimpleLogger::new().init().unwrap();
// A variable to be passed in the task. let mut exec_count = 0;
// Task scheduler with 1000ms loop frequency. let mut scheduler = TaskScheduler::default(chrono::Local);
// Create a task with 2 steps and add it to the scheduler. // The second step fails every second execution. // Append the task to the scheduler. let = scheduler.addtask( TaskBuilder::new(chrono::Local) .every("1 ") .description("A simple task") .add_step("Step 1", || { info!("Hello from step 1"); Ok(Success) // Let the scheduler know this step was a success. }) .add_step("Step 2", move || { if exec_count % 2 == 0 { exec_count += 1; Err(Error) // Indicate that this step was a fail. } else { info!("Hello from step 2"); exec_count += 1; Ok(Success) // Indicate that this step was a success. } }) .build(), );
// Execute the scheduler. scheduler.run().await; }
Author
Stavros Grigoriou (stav121)