teetime.stage.taskfarm

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

java.lang.Object

teetime.framework.CompositeStage

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

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

public class DynamicTaskFarmStage<I,O,T extends ITaskFarmDuplicable<I,O>>
extends StaticTaskFarmStage<I,O,T>

Represents the self-adaptive task farm parallelization pattern in TeeTime. It dynamically adds CPU resources at runtime depending on the current CPU load and the behavior of the parallelized stage.

Author:

Christian Claus Wiechmann, Christoph Dornieden

Field Summary

Fields inherited from class teetime.framework.CompositeStage

DEFAULT_PIPE_CAPACITY

Constructor Summary

Constructors

Constructor and Description
DynamicTaskFarmStage(T workerStage, int initialNumOfStages) Creates a task farm using a worker stage with a pipe capacity of 100.
DynamicTaskFarmStage(T workerStage, int initialNumOfStages, int pipeCapacity) Creates a task farm using a worker stage with a given pipe capacity.

Method Summary

Modifier and Type	Method and Description
ITaskFarmDuplicable<I,O>	addStageAtRuntime() Adds a new enclosed stage at Runtime
ITaskFarmDuplicable<I,O>	getBasicEnclosedStage() Returns the first instance of the worker stages enclosed in the task farm.
TaskFarmConfiguration<I,O,T>	getConfiguration()
ITaskFarmDuplicable<I,O>	removeStageAtRuntime() Dynamically removes a stage from the controlled task farm.

Methods inherited from class teetime.stage.taskfarm.StaticTaskFarmStage

getInputPort, getOutputPort, getPipeCapacity, 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

DynamicTaskFarmStage

public DynamicTaskFarmStage(T workerStage,
                            int initialNumOfStages)

Creates a task farm using a worker stage with a pipe capacity of 100.

Parameters:

workerStage - stage to be parallelized by the task farm

initialNumOfStages - the initial number of stages used by the task farm

DynamicTaskFarmStage

public DynamicTaskFarmStage(T workerStage,
                            int initialNumOfStages,
                            int pipeCapacity)

Creates a task farm using a worker stage with a given pipe capacity.

Parameters:

workerStage - stage to be parallelized by the task farm

pipeCapacity - pipe capacity to be used

initialNumOfStages - the initial number of stages used by the task farm

Method Detail

addStageAtRuntime

public ITaskFarmDuplicable<I,O> addStageAtRuntime()
                                           throws InterruptedException

Adds a new enclosed stage at Runtime

Returns:

new created Stage

Throws:

InterruptedException

removeStageAtRuntime

public ITaskFarmDuplicable<I,O> removeStageAtRuntime()
                                              throws InterruptedException

Dynamically removes a stage from the controlled task farm.

Throws:

InterruptedException

getBasicEnclosedStage

public ITaskFarmDuplicable<I,O> getBasicEnclosedStage()

Returns the first instance of the worker stages enclosed in the task farm.

Returns:

first instance of the worker stages

getConfiguration

public TaskFarmConfiguration<I,O,T> getConfiguration()