Struct ParallelExecutionEngine 

pub struct ParallelExecutionEngine { /* private fields */ }

Parallel execution engine using Rayon thread pool

Implementations

impl ParallelExecutionEngine

pub fn new(policy: ParallelizationPolicy) -> DbxResult<Self>

Create a new parallel execution engine with the specified policy

pub fn new_auto() -> DbxResult<Self>

Create a new parallel execution engine with automatic thread count

pub fn new_fixed(num_threads: usize) -> DbxResult<Self>

Create a new parallel execution engine with a fixed number of threads

pub fn policy(&self) -> ParallelizationPolicy

Get the current parallelization policy

pub fn thread_count(&self) -> usize

Get the number of threads in the thread pool

pub fn thread_pool(&self) -> &ThreadPool

Get a reference to the thread pool

pub fn execute<F, R>(&self, f: F) -> R

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

Execute a closure in the thread pool

pub fn auto_tune(&self, workload_size: usize) -> usize

Auto-tune the thread count based on workload size

Returns the recommended number of parallel tasks for the given workload size

pub fn auto_tune_weighted( &self, workload_size: usize, avg_complexity: f64, ) -> usize

Auto-tune with complexity weight factor

Higher complexity = fewer items per thread needed to justify parallelism

pub fn estimate_query_complexity(sql: &str) -> f64

Estimate SQL query complexity based on heuristics

Returns a complexity score (1.0 = simple SELECT, higher = more complex)

pub fn should_parallelize(&self, workload_size: usize) -> bool

Check if parallelization is beneficial for the given workload size

Trait Implementations

impl Default for ParallelExecutionEngine

fn default() -> Self

Returns the “default value” for a type.