Struct BatchExecutor 

pub struct BatchExecutor {
    pub max_batch_size: usize,
    pub max_concurrent: usize,
    /* private fields */
}

Batch executor for processing multiple items efficiently.

Fields

max_batch_size: usize

Maximum batch size.

max_concurrent: usize

Maximum concurrent batches.

Implementations

impl BatchExecutor

pub fn new() -> Self

Create a new batch executor.

pub fn with_settings(max_batch_size: usize, max_concurrent: usize) -> Self

Create with custom settings.

pub async fn process<T, R, F, Fut>(&self, items: Vec<T>, processor: F) -> Vec<R>

where T: Clone + Send + 'static, R: Send + 'static, F: Fn(T) -> Fut + Clone + Send + Sync + 'static, Fut: Future<Output = R> + Send,

Process items in batches.

pub async fn process_indexed<T, R, F, Fut>( &self, items: Vec<T>, processor: F, ) -> Vec<(usize, R)>

where T: Clone + Send + 'static, R: Send + 'static, F: Fn(usize, T) -> Fut + Clone + Send + Sync + 'static, Fut: Future<Output = R> + Send,

Process items in parallel with index tracking.

Trait Implementations

impl Debug for BatchExecutor

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

Formats the value using the given formatter.

impl Default for BatchExecutor

fn default() -> Self

Returns the “default value” for a type.