teetime.stage.taskfarm

Class StaticTaskFarmStage<I,O,T extends ITaskFarmDuplicable<I,O>>

java.lang.Object

teetime.framework.CompositeStage

teetime.stage.taskfarm.StaticTaskFarmStage<I,O,T>

Type Parameters:

I - Input type of Task Farm

O - Output type of Task Farm

T - Type of the parallelized stage

All Implemented Interfaces:

ITransformation<I,O>

Direct Known Subclasses:

DynamicTaskFarmStage

public class StaticTaskFarmStage<I,O,T extends ITaskFarmDuplicable<I,O>>
extends CompositeStage
implements ITransformation<I,O>

Represents the task farm parallelization pattern in TeeTime.

Author:

Christian Claus Wiechmann, Christian Wulf

Field Summary

Fields inherited from class teetime.framework.CompositeStage

DEFAULT_PIPE_CAPACITY

Constructor Summary

Constructors

Modifier	Constructor and Description
	StaticTaskFarmStage(T workerStage) Creates a task farm stage with n worker stages and a pipe capacity of , where n is
	StaticTaskFarmStage(T workerStage, int numberStages)
	StaticTaskFarmStage(T workerStage, int numberStages, int pipeCapacity)
protected	StaticTaskFarmStage(T workerStage, int numberStages, int pipeCapacity, Distributor<I> distributor, Merger<O> merger)

Method Summary

Modifier and Type	Method and Description
InputPort<I>	getInputPort() Returns the input port of the task farm/distributor of the task farm.
OutputPort<O>	getOutputPort() Returns the output port of the task farm/merger of the task farm.
protected int	getPipeCapacity()
List<ITaskFarmDuplicable<I,O>>	getWorkerStages()

Methods inherited from class teetime.framework.CompositeStage

connectPorts, connectPorts, createInputPort, createOutputPort

Methods inherited from class java.lang.Object

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

Constructor Detail

StaticTaskFarmStage

public StaticTaskFarmStage(T workerStage)

Creates a task farm stage with n worker stages and a pipe capacity of , where n is

 Runtime.getRuntime().availableProcessors()
 

Parameters:

workerStage -

StaticTaskFarmStage

public StaticTaskFarmStage(T workerStage,
                           int numberStages)

StaticTaskFarmStage

public StaticTaskFarmStage(T workerStage,
                           int numberStages,
                           int pipeCapacity)

StaticTaskFarmStage

protected StaticTaskFarmStage(T workerStage,
                              int numberStages,
                              int pipeCapacity,
                              Distributor<I> distributor,
                              Merger<O> merger)

Method Detail

getInputPort

public InputPort<I> getInputPort()

Returns the input port of the task farm/distributor of the task farm.

Specified by:

getInputPort in interface ITransformation<I,O>

Returns:

input port of the task farm

getOutputPort

public OutputPort<O> getOutputPort()

Returns the output port of the task farm/merger of the task farm.

Specified by:

getOutputPort in interface ITransformation<I,O>

Returns:

output port of the task farm

getPipeCapacity

protected int getPipeCapacity()

getWorkerStages

public List<ITaskFarmDuplicable<I,O>> getWorkerStages()

Returns:

a list of all currently existing worker stages