Struct Spawner

pub struct Spawner<const N: usize, Q = MpMcQueue<Pin<Box<dyn Future<Output = ()> + Send + Sync + 'static>>, N>> { /* private fields */ }

A simple task spawner and runner. It can queue multiple futures (tasks) and run them to completion.

Implementations

impl<const N: usize> Spawner<N>

pub const fn new() -> Self

Creates a new, empty Spawner.

pub fn spawn<F>(&self, future: F) -> Result<(), Error>

where F: Future<Output = ()> + 'static + Send + Sync,

Spawns a new task. The provided future will be boxed, pinned, and added to the task queue.

Arguments

• future: The future to spawn. It must be 'static and output ().

pub fn run_until_all_done(&self) -> Result<(), Error>

Runs all spawned tasks to completion. This method will block and continuously poll tasks in a round-robin fashion until all tasks have completed.

Note: If any task never completes (e.g., an infinite loop that never yields Poll::Ready), this method will also loop forever.

Trait Implementations

impl<const N: usize> Default for Spawner<N>

fn default() -> Self

Returns the “default value” for a type.