Struct ParallelPolicy 

pub struct ParallelPolicy {
    pub max_threads: Option<usize>,
    pub utility_threshold: usize,
    pub postprocess_pixel_threshold: usize,
}

Centralized configuration for parallel processing behavior across the OCR pipeline.

This struct consolidates parallel processing configuration that was previously scattered across different components, providing a unified way to tune parallelism behavior throughout the OCR pipeline.

Fields

max_threads: Option<usize>

Maximum number of threads to use for parallel processing. If None, rayon will use the default thread pool size (typically number of CPU cores). Default: None (use rayon’s default)

utility_threshold: usize

Threshold for general utility operations like image loading (<= this uses sequential) Default: 4 (matches DEFAULT_PARALLEL_THRESHOLD constant)

postprocess_pixel_threshold: usize

Threshold for postprocessing operations based on pixel area (<= this uses sequential) Default: 8000 (use sequential for regions with <= 8000 pixels, parallel for larger)

Implementations

impl ParallelPolicy

pub fn new() -> ParallelPolicy

Create a new ParallelPolicy with default values.

pub fn with_max_threads(self, max_threads: Option<usize>) -> ParallelPolicy

Set the maximum number of threads.

pub fn with_postprocess_pixel_threshold( self, threshold: usize, ) -> ParallelPolicy

Set the postprocessing pixel threshold.

pub fn with_utility_threshold(self, threshold: usize) -> ParallelPolicy

Set the utility operations threshold.

pub fn install_global_thread_pool(&self) -> Result<bool, ThreadPoolBuildError>

Install the global rayon thread pool with the configured number of threads.

This method should be called once at application startup before any parallel processing occurs. If max_threads is None, this method does nothing and rayon will use its default thread pool size.

Returns

• Ok(true) if the thread pool was successfully configured
• Ok(false) if max_threads is None (no configuration needed)
• Err if the thread pool has already been initialized

Example

let policy = ParallelPolicy::new().with_max_threads(Some(4));
policy.install_global_thread_pool()?;

Trait Implementations

impl Clone for ParallelPolicy

fn clone(&self) -> ParallelPolicy

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ParallelPolicy

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

Formats the value using the given formatter.

impl Default for ParallelPolicy

fn default() -> ParallelPolicy

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ParallelPolicy

fn deserialize<__D>( __deserializer: __D, ) -> Result<ParallelPolicy, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ParallelPolicy

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.