Struct ParallelContext 

pub struct ParallelContext { /* private fields */ }

Parallel execution context for CPU-bound work

Work runs on the process-wide scheduler rather than a context-owned pool, so several contexts share one worker set instead of over-subscribing the machine with a thread pool each.

Implementations

impl ParallelContext

pub fn new() -> ParallelContext

Create a new parallel context with the default chunk size

pub fn with_chunk_size(chunk_size: usize) -> ParallelContext

Create with specific chunk size

impl ParallelContext

pub fn execute_iter<T, F, R>( &self, items: Vec<T>, func: F, ) -> Result<Vec<R>, Box<dyn Error + Send + Sync>>

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

Execute an iterator operation with parallel processing

pub fn execute<F, R>(&self, func: F) -> Result<R, Box<dyn Error + Send + Sync>>

where F: FnOnce() -> R + Send, R: Send,

Execute a closure with the context

Trait Implementations

impl Clone for ParallelContext

fn clone(&self) -> ParallelContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ParallelContext

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

Formats the value using the given formatter.

impl Default for ParallelContext

fn default() -> ParallelContext

Returns the “default value” for a type.

impl ExecutionBase for ParallelContext

fn context_type(&self) -> &'static str

Get context type name for debugging

fn is_ready(&self) -> bool

Check if the context is ready for execution