Struct meio::prelude::TaskDistributor

pub struct TaskDistributor<T> { /* fields omitted */ }

Set of tasks that can be stopped together.

Implementations

impl<T> TaskDistributor<T>

pub fn new() -> Self

Creates a new set of tasks.

impl<T> TaskDistributor<T>

pub fn insert(&mut self, addr: TaskAddress<T>)

Inserts a task into the set.

pub fn get(&mut self, id: &IdOf<T>) -> Option<&TaskAddress<T>>

Removes a task from the set by IfOd.

pub fn remove(&mut self, id: &IdOf<T>) -> Option<TaskAddress<T>>

Removes a task from the set by IfOd.

pub fn stop_all(&self)

Send stop signal to all tasks.

pub fn len(&self) -> usize

Size of the set of tasks.

pub fn is_empty(&self) -> bool

Is this set empty?

Trait Implementations

impl<T: Debug> Debug for TaskDistributor<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T> Default for TaskDistributor<T>

fn default() -> Self

Returns the “default value” for a type.