Package nz.org.riskscape.engine.pipeline

Interface PipelineExecutor

public interface PipelineExecutor

  • Method Details

    • realize

      RealizedPipeline realize(ExecutionContext executionContext, Pipeline pipeline)

    • execute

      Future<ExecutionResult> execute(PipelineJobContext jobContext)

      Start running the realized pipeline. Note that the returned ExecutionResult can then be used to wait (ExecutionResult#join()) until the pipeline execution has completed.

    • setNumThreads

      void setNumThreads(int threads)

      Sets the number of worker threads that the PipelineExecutor can create and use.

    • getNumThreads

      int getNumThreads()
      Returns:
      the number of worker threads that the PipelineExecutor can create and use.

    • newExecutionContext

      ExecutionContext newExecutionContext(Project project)