Struct tasklet::TaskScheduler

pub struct TaskScheduler<T>
where
    T: TimeZone + Clone + Send + 'static,
{ /* private fields */ }

Task scheduler and executor.

Implementations

impl<T> TaskScheduler<T>

where T: TimeZone + Clone + Send + 'static,

TaskScheduler implementation.

pub fn default(timezone: T) -> TaskScheduler<T>

Create a new instance of TaskSchedule with default sleep and no tasks to execute.

Arguments

• timezone - the scheduler’s timezone.

Examples

let _ = TaskScheduler::default(chrono::Utc);

pub fn new(sleep: usize, timezone: T) -> TaskScheduler<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 _ = TaskScheduler::new(1000, chrono::Local);

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

Set a TaskGenerator instance for the TaskScheduler.

Arguments

• task_gen - a TaskGenerator instance.

Examples

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

pub fn add_task(&mut self, task: Task<T>) -> &mut TaskScheduler<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::default(chrono::Local);
// Add a task that executes every second forever.
scheduler.add_task(Task::new("* * * * * * *", None, None, chrono::Local));

pub async fn run(&mut self)

Main execution loop.

Executes the main flow of the scheduler. At first initialize all the tasks and then run the execution loop.

If there is a task generation/discovery method provided, executed on every loop.