Struct ParallelExecutor 

pub struct ParallelExecutor { /* private fields */ }

Block-STM inspired parallel transaction executor.

Executes batches of operations in parallel with optimistic concurrency control.

Implementations

impl ParallelExecutor

pub fn new(num_workers: usize) -> Self

Creates a new parallel executor with the specified number of workers.

Panics

Panics if num_workers is 0.

pub fn default_workers() -> Self

Creates a parallel executor with the default number of workers (number of CPUs).

pub fn num_workers(&self) -> usize

Returns the number of workers.

pub fn execute_batch<F>( &self, batch: BatchRequest, execute_fn: F, ) -> BatchResult

where F: Fn(usize, &str, &mut ExecutionResult) + Sync + Send,

Executes a batch of operations in parallel.

Operations are executed optimistically in parallel, validated for conflicts, and re-executed as needed. The final result maintains deterministic ordering.

Trait Implementations

impl Default for ParallelExecutor

fn default() -> Self

Returns the “default value” for a type.