tasklet 0.1.1

A task scheduling library.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

use log::info;
use simple_logger::SimpleLogger;
use tasklet::{TaskBuilder, TaskScheduler};

/// An example of a `TaskScheduler` instance with 2 `Task` instances.
fn main() {
    // Initialize the logger.
    SimpleLogger::new().init().unwrap();

    // Just a passed variable.
    let mut count: usize = 5;

    // Create a scheduler instance.
    let mut scheduler = TaskScheduler::new(500, chrono::Utc);

    // Add two tasks, the first one will die after 5 executions,
    // the second will run forever.
    // The first task will execute at seconds 1, 10, 20 of a minute,
    // and the second at the second 30 of each minute.
    scheduler
        .add_task(
            TaskBuilder::new(chrono::Utc)
                .every("1, 10, 20 * * * * * *")
                .description("Just some task")
                .repeat(5)
                .add_step(None, move || {
                    count = count - 1;
                    info!("I have {} more executions left!", count);
                    Ok(())
                })
                .build(),
        )
        .add_task(
            TaskBuilder::new(chrono::Utc)
                .every("30 * * * * * *")
                .description("Just another task")
                .add_step(None, || {
                    info!("I will run forever!");
                    Ok(())
                })
                .build(),
        );

    // Execute the tasks in the queue.
    scheduler.run();
}