Struct ConcurrentExecutor 

pub struct ConcurrentExecutor { /* private fields */ }

Executes tasks concurrently with configurable concurrency limits.

The executor manages parallel execution of tasks while respecting concurrency limits and completion criteria.

Implementations

impl ConcurrentExecutor

pub fn new( total_tasks: usize, max_concurrency: Option<usize>, completion_config: CompletionConfig, ) -> Self

Creates a new ConcurrentExecutor.

Arguments

• total_tasks - Total number of tasks to execute
• max_concurrency - Maximum concurrent tasks (None = unlimited)
• completion_config - Configuration for completion criteria

pub fn counters(&self) -> &Arc<ExecutionCounters>

Returns a reference to the execution counters.

pub fn completion_notify(&self) -> &Arc<Notify>

Returns a reference to the completion notify.

pub fn should_complete(&self) -> Option<CompletionReason>

Checks if the operation should complete based on current state.

pub fn record_success(&self) -> Option<CompletionReason>

Records a successful task completion and checks for overall completion.

Returns Some(CompletionReason) if the operation should now complete.

pub fn record_failure(&self) -> Option<CompletionReason>

Records a failed task and checks for overall completion.

Returns Some(CompletionReason) if the operation should now complete.

pub fn record_suspend(&self) -> Option<CompletionReason>

Records a suspended task and checks for overall completion.

Returns Some(CompletionReason) if the operation should now complete.

pub async fn execute<T, F, Fut>(self, tasks: Vec<F>) -> BatchResult<T>

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

Executes tasks concurrently and returns the batch result.

Arguments

• tasks - Vector of async task functions

Returns

A BatchResult containing results for all tasks.

Trait Implementations

impl Debug for ConcurrentExecutor

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

Formats the value using the given formatter.