Struct TaskExecutor 

pub struct TaskExecutor { /* private fields */ }

Implementations

impl TaskExecutor

pub fn new() -> Self

pub async fn add_running_task(&self, task_id: String)

pub async fn remove_running_task(&self, task_id: &str)

pub async fn running_count(&self) -> usize

pub async fn is_empty(&self) -> bool

pub fn shutdown(&self)

pub fn wait_for_shutdown(&self) -> &Notify

pub async fn wait_for_running_tasks(&self)

Trait Implementations

impl Clone for TaskExecutor

fn clone(&self) -> TaskExecutor

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.