Struct sans_io_runtime::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 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)

Send event to correct task with index

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

Gracefully destroys the task group.

Trait Implementations

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<(usize, Out)> for TaskGroup<In, Out, T, STACK_SIZE>

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

Retrieves the output from the flagged processed task.

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