Struct AdvancedParallelProcessor 

pub struct AdvancedParallelProcessor<F: Float + Display> { /* private fields */ }

Advanced parallel statistics processor

Implementations

impl<F> AdvancedParallelProcessor<F>

where F: Float + NumCast + Send + Sync + SimdUnifiedOps + Copy + 'static + Zero + One + Debug + Display + Sum<F>,

pub fn new(config: AdvancedParallelConfig) -> Self

Create a new advanced parallel processor

pub fn initialize(&mut self) -> StatsResult<()>

Initialize the thread pool with optimal configuration

pub fn mean_parallel_advanced<D>(&self, x: &ArrayBase<D, Ix1>) -> StatsResult<F>

where D: Data<Elem = F> + Sync + Send,

Compute mean using advanced parallel processing

pub fn variance_parallel_advanced<D>( &self, x: &ArrayBase<D, Ix1>, ddof: usize, ) -> StatsResult<F>

where D: Data<Elem = F> + Sync + Send,

Compute variance using advanced parallel processing with numerical stability

pub fn correlation_matrix_parallel<D>( &self, data: &ArrayBase<D, Ix2>, ) -> StatsResult<Array2<F>>

where D: Data<Elem = F> + Sync + Send,

Compute correlation matrix in parallel for multivariate data

pub fn batch_statistics_parallel<D>( &self, x: &ArrayBase<D, Ix1>, ddof: usize, ) -> StatsResult<ComprehensiveStats<F>>

where D: Data<Elem = F> + Sync + Send,

Batch parallel processing for multiple statistical operations

pub fn bootstrap_parallel<D>( &self, x: &ArrayBase<D, Ix1>, n_samples_: usize, statistic_fn: impl Fn(&ArrayView1<'_, F>) -> F + Send + Sync + Clone, seed: Option<u64>, ) -> StatsResult<Array1<F>>

where D: Data<Elem = F> + Sync + Send,

Parallel bootstrap resampling with intelligent load balancing