Struct TaskGroup

pub struct TaskGroup<In, Out, T: Task<In, Out>, const STACK_SIZE: usize> { /* private fields */ }

Represents a group of tasks.

Implementations

impl<In, Out, T: Task<In, Out>, const STACK_SIZE: usize> TaskGroup<In, Out, T, STACK_SIZE>

pub fn tasks(&self) -> usize

Returns the number of tasks in the group.

pub fn has_task(&self, index: usize) -> bool

Check if we have task with index

pub fn add_task(&mut self, task: T) -> usize

Adds a task to the group.

pub fn set_task(&mut self, index: usize, task: T) -> usize

Set task to a slot index

pub fn remove_task(&mut self, index: usize)

Remove a task from the group

pub fn on_tick(&mut self, now: Instant)

Fire tick event to all tasks, after that we need to call pop_output util it return None

pub fn on_event(&mut self, now: Instant, index: usize, input: In) -> Option<()>

Send event to correct task with index

pub fn on_shutdown(&mut self, now: Instant)

Gracefully destroys the task group.

Trait Implementations

impl<In: Debug, Out: Debug, T: Debug + Task<In, Out>, const STACK_SIZE: usize> Debug for TaskGroup<In, Out, T, STACK_SIZE>

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

Formats the value using the given formatter.

impl<In, Out, T: Task<In, Out>, const STACK_SIZE: usize> Default for TaskGroup<In, Out, T, STACK_SIZE>

fn default() -> Self

Creates a new task group with the specified worker ID.

impl<In, Out, T: Task<In, Out>, const STACK_SIZE: usize> TaskSwitcherChild<TaskGroupOutput<Out>> for TaskGroup<In, Out, T, STACK_SIZE>

fn pop_output(&mut self, now: Self::Time) -> Option<TaskGroupOutput<Out>>

Retrieves the output from the flagged processed task.

type Time = <T as TaskSwitcherChild<Out>>::Time

fn empty_event(&self) -> TaskGroupOutput<Out>

fn is_empty(&self) -> bool