Struct ConcurrentExecutor 

pub struct ConcurrentExecutor { /* private fields */ }

Executor for running concurrent tasks with controlled parallelism.

Implementations

impl ConcurrentExecutor

pub fn new(config: ConcurrencyConfig) -> Self

Create a new concurrent executor.

pub async fn execute_all<T, F, Fut>( &self, tasks: impl IntoIterator<Item = F>, ) -> (Vec<TaskResult<T>>, ExecutionStats)

where F: FnOnce() -> Fut + Send + 'static, Fut: Future<Output = Result<T, String>> + Send + 'static, T: Send + 'static,

Execute all tasks concurrently with controlled parallelism.

Tasks are started immediately but limited by the semaphore to ensure at most max_concurrency tasks run at once.

pub async fn execute_collect<T, F, Fut>( &self, tasks: impl IntoIterator<Item = F>, ) -> (Vec<T>, Vec<TaskError>)

where F: FnOnce() -> Fut + Send + 'static, Fut: Future<Output = Result<T, String>> + Send + 'static, T: Send + 'static,

Execute tasks and collect only successful results.

Returns the values in the same order as the input tasks.

pub async fn execute_indexed<T, F, Fut>( &self, tasks: impl IntoIterator<Item = F>, ) -> HashMap<usize, Result<T, TaskError>>

where F: FnOnce() -> Fut + Send + 'static, Fut: Future<Output = Result<T, String>> + Send + 'static, T: Send + 'static,

Execute tasks with indexed results.

Returns a map of task_id -> result, useful when you need to correlate results with their original indices.