Struct tasklet::TaskScheduler

pub struct TaskScheduler<'a, T> where
    T: TimeZone + Clone,  { /* fields omitted */ }

Task scheduler and executor.

Implementations

impl<'a, T> TaskScheduler<'a, T> where
    T: TimeZone + Clone, 

TaskScheduler implementation.

pub fn new(sleep: usize, timezone: T) -> TaskScheduler<'a, T>

Create a new instance of TaskScheduler with no tasks to execute.

Arguments

• sleep - The execution frequency (in ms).
• timezone - The scheduler's timezone.

Examples

// Create a new `TaskScheduler` instance that executes every 1000ms.
let _schedule = TaskScheduler::new(1000, chrono::Local);

pub fn set_task_gen(
    &mut self,
    task_gen: TaskGenerator<'a, T>
) -> &mut TaskScheduler<'a, T>

Set a TaskGenerator inistance for the TaskScheduler.

Arguments

• task_gen - a TaskGenerator instance.

Examples

// Create a new `TashSceduler` instance and attach an `TaskGenerator` to it.
let mut scheduler = TaskScheduler::new(1000, chrono::Local);
let mut generator = TaskGenerator::new("1 * * * * * *", chrono::Local, || None);
scheduler.set_task_gen(generator);

pub fn add_task(&mut self, task: Task<'a, T>) -> &mut TaskScheduler<'a, T>

Add a new task in the execution queue.

Arguments

• task - a Task instance.

Examples

// Create a new `TaskScheduler` and attach a task to it.
let mut scheduler = TaskScheduler::new(1000, chrono::Local);
// Add a task that executes every second forever.
scheduler.add_task(Task::new("* * * * * * *", None, None, chrono::Local));

pub fn run(&mut self)

Main execution loop.