Package nz.org.riskscape.engine.pipeline

Class DefaultPipelineExecutor

java.lang.Object

nz.org.riskscape.engine.pipeline.DefaultPipelineExecutor

All Implemented Interfaces:

nz.org.riskscape.engine.pipeline.PipelineExecutor

Direct Known Subclasses:

SchedulerBasedExecutor

public abstract class DefaultPipelineExecutor
extends Object
implements nz.org.riskscape.engine.pipeline.PipelineExecutor

Field Summary

Fields

Modifier and Type	Field	Description
protected final nz.org.riskscape.engine.Engine	engine

Constructor Summary

Constructors

Constructor	Description
DefaultPipelineExecutor(nz.org.riskscape.engine.Engine engine)

Method Summary

Modifier and Type	Method	Description
int	getNumThreads()
boolean	isParallelizationEnabled()
nz.org.riskscape.engine.pipeline.ExecutionContext	newExecutionContext(nz.org.riskscape.engine.Project project)
void	setNumThreads(int numThreads)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface nz.org.riskscape.engine.pipeline.PipelineExecutor

execute

Field Details

engine

protected final nz.org.riskscape.engine.Engine engine

Constructor Details

DefaultPipelineExecutor

public DefaultPipelineExecutor(nz.org.riskscape.engine.Engine engine)

Method Details

newExecutionContext

public nz.org.riskscape.engine.pipeline.ExecutionContext newExecutionContext(nz.org.riskscape.engine.Project project)

Specified by:

newExecutionContext in interface nz.org.riskscape.engine.pipeline.PipelineExecutor

isParallelizationEnabled

public boolean isParallelizationEnabled()

getNumThreads

public int getNumThreads()

Specified by:

getNumThreads in interface nz.org.riskscape.engine.pipeline.PipelineExecutor

setNumThreads

public void setNumThreads(int numThreads)

Specified by:

setNumThreads in interface nz.org.riskscape.engine.pipeline.PipelineExecutor