Enum Parallelism 

pub enum Parallelism {
    Serial,
    Custom(fn(count: usize, body: &(dyn Fn(usize) + Sync + Send))),
}

Strategy for dispatching row-parallel work inside batch codec methods.

Variants

Serial

Execute rows sequentially on the current thread.

Custom(fn(count: usize, body: &(dyn Fn(usize) + Sync + Send)))

Defer to a caller-supplied driver (e.g. rayon).

The driver is a plain function pointer, so it cannot close over state such as a specific rayon::ThreadPool. To target a non-global pool, install it before invoking compress_batch_with: pool.install(|| codec.compress_batch_with(..., Parallelism::Custom(driver))).

Implementations

impl Parallelism

pub fn for_each_row<F>(self, count: usize, body: F)

where F: Fn(usize) + Sync + Send,

Drive body once per row, honoring the selected strategy.

Trait Implementations

impl Clone for Parallelism

fn clone(&self) -> Parallelism

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for Parallelism

fn default() -> Parallelism

Returns the “default value” for a type.

impl Copy for Parallelism