Trait captain_workflow_manager::executor::ExecutorBuilder

pub trait ExecutorBuilder {
    type Executor: Executor;
    fn init<J: JobUnit>(
        self
    ) -> (Self::Executor, Sender<ToRun<J>>, Sender<ExecutorResult>, Receiver<ExecutorResult>);
}

Trait used to implement the function creating the communication channels and starting the worker threads.

Associated Types

type Executor: Executor

The associated Executor type.

Required methods

fn init<J: JobUnit>(
    self
) -> (Self::Executor, Sender<ToRun<J>>, Sender<ExecutorResult>, Receiver<ExecutorResult>)

Creates the communication channel ToRun and Results

The executor should accept jobs to run on ToRun, run them, and send the executor result on Results.

Returns

1. The Executor object,
2. The send end of crossbeam communication channel ToRun,
3. The send end of the crossbeam channel Results,
4. The receive end of the crossbeam channel Results.

Implementors

impl ExecutorBuilder for DryRunExecutorBuilder

type Executor = DryRunExecutor

impl ExecutorBuilder for SlurmExecutorBuilder

type Executor = SlurmExecutor

impl ExecutorBuilder for ThreadLocalExecutorBuilder

type Executor = ThreadLocalExecutor