Package nz.org.riskscape.engine.pipeline

Interface PipelineExecutor

public interface PipelineExecutor

Method Summary

Modifier and Type	Method	Description
Future<ExecutionResult>	execute(PipelineJobContext jobContext)	Start running the realized pipeline.
int	getNumThreads()
ExecutionContext	newExecutionContext(Project project)
void	setNumThreads(int threads)	Sets the number of worker threads that the PipelineExecutor can create and use.

Method Details

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)