teetime.stage.taskfarm

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

java.lang.Object

teetime.framework.CompositeStage

teetime.stage.taskfarm.TaskFarmStage<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>

Deprecated.

since 3.0. Use StaticTaskFarmStage instead.

@Deprecated
public class TaskFarmStage<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
	TaskFarmStage(T workerStage) Deprecated. Creates a task farm stage with n worker stages and a pipe capacity of , where n is
	TaskFarmStage(T workerStage, int numberStages) Deprecated.
	TaskFarmStage(T workerStage, int numberStages, int pipeCapacity) Deprecated.
protected	TaskFarmStage(T workerStage, int numberStages, int pipeCapacity, Distributor<I> distributor, Merger<O> merger) Deprecated.

Method Summary

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

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

TaskFarmStage

public TaskFarmStage(T workerStage)

Deprecated.

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

 Runtime.getRuntime().availableProcessors()
 

Parameters:

workerStage -

TaskFarmStage

public TaskFarmStage(T workerStage,
                     int numberStages)

Deprecated.

TaskFarmStage

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

Deprecated.

TaskFarmStage

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

Deprecated.

Method Detail

getInputPort

public InputPort<I> getInputPort()

Deprecated.

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()

Deprecated.

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()

Deprecated.

getWorkerStages

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

Deprecated.

Returns:

a list of all currently existing worker stages