Struct BatchProcessor 

pub struct BatchProcessor { /* private fields */ }

Parallel batch processor for audio operations

Implementations

impl BatchProcessor

pub fn new(batch_size: usize) -> Self

Create new batch processor

pub fn with_threads(self, num_threads: usize) -> Self

Set number of threads for parallel processing

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

where T: Send, F: Fn(T) -> R + Send + Sync, R: Send,

Process items in parallel batches

pub fn process_chunks<F>( &self, data: &Array2<f32>, chunk_size: usize, f: F, ) -> Vec<Array2<f32>>

where F: Fn(ArrayView2<'_, f32>) -> Array2<f32> + Send + Sync,

Process audio buffers in chunks