Struct TaskSet 

pub struct TaskSet<T> { /* private fields */ }

A set of spawned tasks, joined as they complete — the seam replacement for tokio::task::JoinSet.

JoinSet is a fourth spelling of tokio::spawn, and the one no seam guard caught: JoinSet::spawn calls tokio::spawn internally, so it panics with “there is no reactor running” on any thread that is not inside a tokio runtime — which on RTEMS is every callback-band worker. Measured on target: the CA client’s transport manager died on cbMedium at its first connect (doc/calink-rtems-design.md §11.1). Naming it here means a call site can express “spawn a set of tasks and reap them as they finish” without reaching past the seam.

The three properties call sites depend on, all preserved:

• Concurrency — every member runs independently; joining one does not block the others.
• Pair-by-value — Self::join_next yields whichever member finished first, so a task that returns its own key can be matched to its state.
• Abort on drop — dropping the set cancels every member that has not finished, which is the property that distinguishes a JoinSet from a bag of detached JoinHandles.

Implementations

impl<T> TaskSet<T>

pub fn new() -> Self

An empty set.

pub fn len(&self) -> usize

Number of members that have not yet been joined.

pub fn is_empty(&self) -> bool

true when no member is outstanding.

impl<T: Send + 'static> TaskSet<T>

pub fn spawn<F>(&mut self, future: F)

where F: Future<Output = T> + Send + 'static,

Spawn future into the set — through spawn, so the RTEMS build lands it on a callback band instead of demanding a tokio runtime.

pub async fn join_next(&mut self) -> Option<Result<T, TaskJoinError>>

Wait for the next member to finish and return its result, removing it from the set. None when the set is empty — matching JoinSet::join_next, so a select! arm on it goes quiet rather than spinning once every task has been reaped.

Cancel-safe: the returned future holds no state of its own, so a select! that drops it loses nothing.

Trait Implementations

impl<T> Default for TaskSet<T>

fn default() -> Self

Returns the “default value” for a type.

impl<T> Drop for TaskSet<T>

fn drop(&mut self)

Cancel every outstanding member — JoinSet’s drop behaviour, and the reason a call site reaches for a set rather than a Vec of handles.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.