Enum Executor 

pub enum Executor {
    Sequential(SequentialExecutor),
    Tokio(TokioExecutor),
    Rayon(RayonExecutor),
}

Unified executor enum combining all concurrency strategies.

Wraps different executor implementations in a single enum for type-safe usage. Automatically routes to appropriate implementation based on configuration.

Variants

Sequential(SequentialExecutor)

Sequential executor (always available).

Tokio(TokioExecutor)

Tokio async executor (always available).

Rayon(RayonExecutor)

Rayon parallel executor (requires parallel feature).

Implementations

impl Executor

pub fn sequential() -> Self

Create Sequential executor.

pub fn tokio(max_concurrent: usize) -> Self

Create Tokio executor with concurrency limit.

pub fn rayon(num_threads: Option<usize>) -> Result<Self, ExecutionError>

Create Rayon executor with optional thread count (requires parallel feature).

pub fn name(&self) -> &str

Get executor implementation name for debugging.

pub async fn execute_batch<F, T>( &self, items: Vec<T>, op: F, ) -> Result<Vec<Result<(), ExecutionError>>, ExecutionError>

where F: Fn(T) -> Result<(), ExecutionError> + Send + Sync + 'static, T: Send + 'static,

Execute operation on batch of items concurrently.

Returns vector of results in same order as input items. Individual item failures don’t stop processing of other items.

Trait Implementations

impl Debug for Executor

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

Formats the value using the given formatter.