teetime.framework

Class DivideAndConquerStage<P extends AbstractDivideAndConquerProblem<P,S>,S extends AbstractDivideAndConquerSolution<S>>

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.DivideAndConquerStage<P,S>

Type Parameters:

P - type of elements that represent a problem to be solved.

S - type of elements that represent the solution to a problem.

All Implemented Interfaces:

ITransformation<P,S>

public class DivideAndConquerStage<P extends AbstractDivideAndConquerProblem<P,S>,S extends AbstractDivideAndConquerSolution<S>>
extends AbstractStage
implements ITransformation<P,S>

A stage to solve divide and conquer problems

Author:

Robin Mohr, Christian Wulf

Field Summary

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor and Description
DivideAndConquerStage() Creates a new divide and conquer stage and connects the additional in- and output ports with DivideAndConquerRecursivePipe with a default threshold of Runtime.getRuntime().availableProcessors().
DivideAndConquerStage(int maxCopiedInstances) Creates a new divide and conquer stage and connects the additional in- and output ports with DivideAndConquerRecursivePipe.

Method Summary

Modifier and Type	Method and Description
protected void	execute() Contains the logic of this stage and is invoked (possibly multiple times) by the framework.
InputPort<P>	getInputPort()
OutputPort<S>	getOutputPort()

Methods inherited from class teetime.framework.AbstractStage

abort, addInputPortRemovedListener, addOutputPortRemovedListener, compareAndSetBeingExecuted, createInputPort, createInputPort, createInputPort, createInputPort, createOutputPort, createOutputPort, createOutputPort, createOutputPort, declareActive, declarePassive, executeByFramework, getCurrentState, getId, getInputPorts, getOutputPorts, getOwningThread, getTerminationStrategy, isActive, isBeingExecuted, isPaused, isProducer, isStateless, onSignal, onStarting, onTerminating, onValidating, removeDynamicPort, removeDynamicPort, setPaused, setStateless, shouldBeTerminated, signalAlreadyReceived, terminateStage, toString, workCompleted

Methods inherited from class java.lang.Object

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

Constructor Detail

DivideAndConquerStage

public DivideAndConquerStage()

Creates a new divide and conquer stage and connects the additional in- and output ports with DivideAndConquerRecursivePipe with a default threshold of Runtime.getRuntime().availableProcessors().

DivideAndConquerStage

public DivideAndConquerStage(int maxCopiedInstances)

Creates a new divide and conquer stage and connects the additional in- and output ports with DivideAndConquerRecursivePipe.

Method Detail

execute

protected void execute()

Description copied from class: AbstractStage

Contains the logic of this stage and is invoked (possibly multiple times) by the framework.

Specified by:

execute in class AbstractStage

getInputPort

public final InputPort<P> getInputPort()

Specified by:

getInputPort in interface ITransformation<P extends AbstractDivideAndConquerProblem<P,S>,S extends AbstractDivideAndConquerSolution<S>>

Returns:

InputPort

getOutputPort

public final OutputPort<S> getOutputPort()

Specified by:

getOutputPort in interface ITransformation<P extends AbstractDivideAndConquerProblem<P,S>,S extends AbstractDivideAndConquerSolution<S>>

Returns:

OutputPort