Struct TaskSupervisor 

pub struct TaskSupervisor { /* private fields */ }

Retains every runtime join until observed complete.

Implementations

impl TaskSupervisor

pub fn new() -> Self

Empty supervisor.

pub fn registered_count(&self) -> usize

Number of tasks still registered (including abort-requested).

pub fn is_empty(&self) -> bool

Whether stopped proof can assert zero owned tasks.

pub fn tasks_for(&self, tx: &TransactionId) -> Vec<TaskId>

Tasks still associated with a transaction.

pub fn spawn<F>(&mut self, class: TaskClass, future: F) -> TaskId

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

Register then spawn. The future does not run until after registration completes (start-gate released at the end of this method).

pub fn abort(&mut self, id: TaskId)

Request abort; task remains registered until join is observed.

pub fn abort_transaction(&mut self, tx: &TransactionId)

Abort all tasks for a transaction.

pub fn abort_transaction_residuals(&mut self, tx: &TransactionId)

Abort residual tx work but keep TaskClass::Finalizer and TaskClass::EventPublisher alive so Seal + completion publication can finish (one completion per admission).

pub fn abort_transaction_except_finalizer(&mut self, tx: &TransactionId)

Hard-grace abort: keep only TaskClass::Finalizer so Seal→completion can finish; abort a stuck EventPublisher that already Sealed or timed out.

pub fn abort_all(&mut self)

Abort every registered task (shutdown).

pub async fn abort_and_drain(&mut self) -> bool

Abort all tasks and observe joins until the set is empty.

Returns false if joins do not complete within the bound — caller MUST remain Quiescing (never report Stopped while owned work remains). Live JoinHandles are retained (§7.3 / §21: no drop on deadline).

pub async fn join_next(&mut self) -> Option<(TaskId, TaskClass, TaskExit)>

Poll for the next finished task and deregister it.

pub fn try_reap_finished(&mut self) -> Vec<(TaskId, TaskClass, TaskExit)>

Non-blocking reap of already-finished joins.

Trait Implementations

impl Debug for TaskSupervisor

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

Formats the value using the given formatter.

impl Default for TaskSupervisor

fn default() -> Self

Returns the “default value” for a type.