teetime.stage.taskfarm.adaptation

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

java.lang.Object

java.lang.Thread

teetime.stage.taskfarm.adaptation.AdaptationThread<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:

Runnable

public class AdaptationThread<I,O,T extends ITaskFarmDuplicable<I,O>>
extends Thread

Represents the adaptation thread used implement the self-adaptive behavior of the task farm.

Author:

Christian Claus Wiechmann

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
AdaptationThread(DynamicTaskFarmStage<I,O,T> taskFarmStage) Creates an adaptation thread for the given task farm.

Method Summary

Modifier and Type	Method and Description
TaskFarmHistoryService<I,O,T>	getHistoryService() Returns the TaskFarmHistoryService of this adaptation thread, containing pipe throughput measurements.
PipeMonitoringService	getPipeMonitoringService()
SingleTaskFarmMonitoringService	getTaskFarmMonitoringService()
void	run() Start the execution of the adaptation thread.
void	stopAdaptationThread() Terminate the adaptation thread.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

AdaptationThread

public AdaptationThread(DynamicTaskFarmStage<I,O,T> taskFarmStage)

Creates an adaptation thread for the given task farm.

Parameters:

taskFarmStage - given task farm instance

Method Detail

run

public void run()

Start the execution of the adaptation thread. The execution should happen after the start of the merger of the corresponding task farm.

Specified by:

run in interface Runnable

Overrides:

run in class Thread

stopAdaptationThread

public void stopAdaptationThread()

Terminate the adaptation thread. The termination should happen after the termination of the merger of the corresponding task farm.

getHistoryService

public TaskFarmHistoryService<I,O,T> getHistoryService()

Returns the TaskFarmHistoryService of this adaptation thread, containing pipe throughput measurements.

Returns:

TaskFarmHistoryService of this adaptation thread

getPipeMonitoringService

public PipeMonitoringService getPipeMonitoringService()

getTaskFarmMonitoringService

public SingleTaskFarmMonitoringService getTaskFarmMonitoringService()