Trait ParallelExecutor

pub trait ParallelExecutor {
    type Task: Future + Send + 'static;

    // Required methods
    fn create_task<F>(func: F) -> Self::Task
       where F: FnOnce() -> Result<(Word, usize), PredicateVerificationFailed> + Send + 'static;
    fn execute_tasks<'async_trait>(
        futures: Vec<Self::Task>,
    ) -> Pin<Box<dyn Future<Output = Vec<Result<(Word, usize), PredicateVerificationFailed>>> + Send + 'async_trait>>
       where Self: 'async_trait;
}

Executes CPU-heavy tasks in parallel.

Required Associated Types

type Task: Future + Send + 'static

Future created from a CPU-heavy task.

Required Methods

fn create_task<F>(func: F) -> Self::Task

where F: FnOnce() -> Result<(Word, usize), PredicateVerificationFailed> + Send + 'static,

Creates a Future from a CPU-heavy task.

fn execute_tasks<'async_trait>( futures: Vec<Self::Task>, ) -> Pin<Box<dyn Future<Output = Vec<Result<(Word, usize), PredicateVerificationFailed>>> + Send + 'async_trait>>

where Self: 'async_trait,

Executes tasks created by create_task in parallel.

Object Safety

This trait is not object safe.

Implementors