Struct ExecCtx 

pub struct ExecCtx<E = Box<dyn Error + Sync + Send>> { /* private fields */ }

One execution context with task memoization, cancellation, and dependency coalescing.

Implementations

impl<E> ExecCtx<E>

where E: Send + Sync + 'static,

pub fn cancel_token(&self) -> &CancelToken

Cancellation token associated with this execution context.

pub fn is_cancelled(&self) -> bool

Whether this execution context has been cancelled.

pub fn child(&self) -> ExecCtx<E>

Create a child execution context with shared memoization and child cancellation.

pub async fn run_parallel( &self, tasks: impl IntoIterator<Item = PreparedTask<E>>, ) -> Result<(), Error<E>>

Run prepared tasks concurrently in a shared child execution context.

All prepared tasks share one execution context for memoization, and the first failing sibling cancels the remaining siblings.

Trait Implementations

impl<E> Clone for ExecCtx<E>

fn clone(&self) -> ExecCtx<E>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<E> Debug for ExecCtx<E>

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

Formats the value using the given formatter.