Struct ParallelBatchProcessor 

pub struct ParallelBatchProcessor { /* private fields */ }

Parallel batch processor with work-stealing queues

Implementations

impl ParallelBatchProcessor

pub fn new(config: BatchConfig) -> Self

Create a new parallel batch processor

pub fn set_progress_callback<F>(&self, callback: F)

where F: Fn(usize, usize) + Send + Sync + 'static,

Set a progress callback

pub fn cancel(&self)

Cancel ongoing operations

pub fn is_cancelled(&self) -> bool

Check if operations are cancelled

pub fn stats(&self) -> BatchStatsSummary

Get current statistics

pub fn errors(&self) -> Vec<OxirsError>

Get accumulated errors

pub fn clear_errors(&self)

Clear accumulated errors

pub fn submit(&self, operation: BatchOperation) -> Result<(), OxirsError>

Submit a batch operation

pub fn submit_batch( &self, operations: Vec<BatchOperation>, ) -> Result<(), OxirsError>

Submit multiple operations

pub fn process<E, R>(&self, executor: E) -> Result<Vec<R>, OxirsError>

where E: Fn(BatchOperation) -> Result<R, OxirsError> + Send + Sync + 'static, R: Send + 'static,

Process operations with the given executor

pub fn process_rayon<E, R>(&self, executor: E) -> Result<Vec<R>, OxirsError>

where E: Fn(BatchOperation) -> Result<R, OxirsError> + Send + Sync, R: Send,

Process operations in parallel using rayon