Struct ParallelRuntime 

pub struct ParallelRuntime { /* private fields */ }

Selects where parallel traversal jobs execute.

The default uses the process-wide Weavatrix pool. Dedicated pools are joined on last drop. External executors receive the configured busy timeout and may reject submission without leaving a traversal waiting for a worker.

Implementations

impl ParallelRuntime

pub fn global() -> Self

Returns the process-wide default runtime.

pub fn dedicated(parallelism: usize) -> Result<Self>

Creates an owned pool with exactly parallelism.max(1) workers.

Errors

Returns an operating-system thread creation error.

pub fn external(executor: Arc<dyn ParallelExecutor>) -> Self

Uses an application-owned executor.

pub fn with_busy_timeout(self, busy_timeout: Option<Duration>) -> Self

Supplies the maximum wait an external executor may use to accept work.

pub fn parallelism(&self) -> usize

Maximum useful worker count advertised by this runtime.

Trait Implementations

impl Clone for ParallelRuntime

fn clone(&self) -> ParallelRuntime

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ParallelRuntime

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

Formats the value using the given formatter.

impl Default for ParallelRuntime

fn default() -> Self

Returns the “default value” for a type.