Struct Executor 

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

Fail-fast executor. Constructed by execute_concurrently.

On the first task error: cancels the rest and returns Error::TaskFailed.

Implementations

impl<T> Executor<T>

where T: Send + 'static,

pub fn with_cancellation(self, token: CancellationToken) -> Self

Attach a cancellation token. Cancelling it requests all running tasks to stop.

Cooperative cancellation

Each task receives the token via the closure argument and is responsible for .cancelled().await-ing it. Tasks that ignore the token will not be interrupted — JoinSet::shutdown aborts their JoinHandles, but a CPU-bound task that never yields cannot be preempted. Design tasks to check the token at await points.

pub fn with_timeout(self, timeout: Duration) -> Self

Apply an overall timeout. If the timeout elapses, Error::Timeout is returned and the internal cancellation token is signalled so remaining tasks observe cancellation. Tasks that ignore the token continue running until they yield (see Self::with_cancellation).

pub fn with_partial_results(self) -> PartialExecutor<T>

Switch to partial-results mode: every task is awaited; each task’s Result appears in the returned PartialResults map.

The outer Result still reports infrastructure errors (Error::Timeout, Error::Cancelled, Error::Join).

Trait Implementations

impl<T> IntoFuture for Executor<T>

where T: Send + 'static,

type Output = Result<HashMap<&'static str, T>, Error>

The output that the future will produce on completion.

type IntoFuture = Pin<Box<dyn Future<Output = <Executor<T> as IntoFuture>::Output> + Send>>

Which kind of future are we turning this into?

fn into_future(self) -> Self::IntoFuture

Creates a future from a value.