Struct TaskManager 

pub struct TaskManager { /* private fields */ }

Starts & tracks Tasks that implement Run

Implementations

impl TaskManager

pub fn new() -> Self

Constructs a new TaskManager.

impl TaskManager

pub fn add(&mut self, name: &str, task: Arc<dyn Run>)

Add a task to run only once. It needs to implement its own internal repeat logic if need be.

pub fn add_interval( &mut self, name: &str, task: Arc<dyn Run>, interval: Duration, )

Add a task to run with a given interval. Errors are printed with a WARN level and then ignored.

pub fn start(&self)

Start the tasks

pub async fn stop(&self)

Signal the tasks to stop and wait until they do. If one or more tasks aren’t acting on the token cancellation signal then this will hang forever.

pub fn token(&self) -> CancellationToken

Return a cancellation token that can be used to signal external tasks when TaskManager is stopping.