Struct ParallelBatchProcessorBuilder 

pub struct ParallelBatchProcessorBuilder<Item> { /* private fields */ }

Builder for ParallelBatchProcessor.

Use the builder when the default worker count, sequential fallback threshold, progress interval, or reporter should be customized.

use qubit_batch::ParallelBatchProcessor;

let processor = ParallelBatchProcessor::builder(|_item: &i32| {})
    .thread_count(2)
    .sequential_threshold(0)
    .build()
    .expect("parallel processor configuration should be valid");

assert_eq!(processor.thread_count(), 2);
assert_eq!(processor.sequential_threshold(), 0);

Implementations

impl<Item> ParallelBatchProcessorBuilder<Item>

pub fn new<C>(consumer: C) -> Self

where C: Consumer<Item> + Send + Sync + 'static,

Creates a builder from a thread-safe consumer.

Parameters

• consumer - Thread-safe consumer invoked once for each accepted item.

Returns

A builder initialized with default parallel processor settings.

pub const fn thread_count(self, thread_count: usize) -> Self

Sets the worker-thread count.

Parameters

• thread_count - Number of scoped worker threads to use.

Returns

This builder for fluent configuration.

pub const fn sequential_threshold(self, sequential_threshold: usize) -> Self

Sets the sequential fallback threshold.

Parameters

• sequential_threshold - Maximum declared item count that still runs on the caller thread. Use 0 when every non-empty batch should use scoped workers.

Returns

This builder for fluent configuration.

pub const fn report_interval(self, report_interval: Duration) -> Self

Sets the progress-report interval.

Parameters

• report_interval - Minimum time between due-based running progress callbacks. Duration::ZERO reports at every sequential between-item progress point or on parallel worker completion signals without periodic polling.

Returns

This builder for fluent configuration.

pub fn reporter<R>(self, reporter: R) -> Self

where R: ProgressReporter + 'static,

Sets the progress reporter used by built processors.

Parameters

• reporter - Progress reporter used for later processing calls.

Returns

This builder for fluent configuration.

pub fn reporter_arc(self, reporter: Arc<dyn ProgressReporter>) -> Self

Sets the shared progress reporter used by built processors.

Parameters

• reporter - Shared progress reporter used for later processing calls.

Returns

This builder for fluent configuration.

pub fn no_reporter(self) -> Self

Disables progress callbacks by using NoOpProgressReporter.

Returns

This builder for fluent configuration.

pub fn build( self, ) -> Result<ParallelBatchProcessor<Item>, ParallelBatchProcessorBuildError>

Builds a validated ParallelBatchProcessor.

Returns

A parallel batch processor when the configuration is valid.

Errors

Returns ParallelBatchProcessorBuildError when the worker count is zero.