Struct BoundedExecutor 

pub struct BoundedExecutor { /* private fields */ }

Implementations

impl BoundedExecutor

pub fn new(max_parallelism: NonZeroUsize) -> Self

pub fn with_pool( max_parallelism: NonZeroUsize, pool: SharedExecutorPool, ) -> Self

pub fn max_parallelism(&self) -> usize

pub fn is_degraded(&self) -> bool

pub fn pool_error(&self) -> Option<&SharedExecutorPoolError>

pub fn map_ordered<T, R, F>(self, inputs: &[T], operation: F) -> Vec<R>

where T: Sync, R: Send, F: Fn(&T) -> R + Sync,

Materializes one output per input in input order, regardless of completion order. An output that is itself a Result does not short-circuit workers. This bounds worker concurrency, not the collected vector’s memory.

pub fn map_ordered_with_context<T, R, F>( self, inputs: &[T], context: &RuntimeTaskContext, operation: F, ) -> Result<Vec<R>, RuntimeCancellationReason>

where T: Sync, R: Send, F: Fn(&T) -> R + Sync,

The materializing map with cooperative cancellation checks. In-flight callbacks may finish after cancellation; no partial vector is returned.

Trait Implementations

impl Clone for BoundedExecutor

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BoundedExecutor

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

Formats the value using the given formatter.

impl Default for BoundedExecutor

fn default() -> Self

Returns the “default value” for a type.