Struct dager::executor::Executor

pub struct Executor { /* fields omitted */ }

Gets all the jobs an schedules them onto its inner threads. Is save to be cloned since it is only a managing reference to the threads.

When dropped, all executing jobs are finshed. However, jobs that are in line are not started. So this obj needs to be kept alive as long as you want to execute any jobs.

Implementations

impl Executor

pub fn new() -> Arc<Self>

pub fn new_with_threads(num_threads: usize) -> Arc<Self>

pub fn schedule(&self, new_task: Task) -> Result<(), ExecutorError>

Puts this task into the scheduler queue. The executor works via FIFO principle.

pub fn shutdown(&self)

Graceful shutdown of the executor, by waiting (and blocking) for all tasks to finish. If you don't need that, just drop the executor, which will kill all threads as fast as possible.