teetime.framework.scheduling.globaltaskpool

Class GlobalTaskPoolScheduling

java.lang.Object

teetime.framework.scheduling.globaltaskpool.GlobalTaskPoolScheduling

All Implemented Interfaces:

Thread.UncaughtExceptionHandler, PipeScheduler, TeeTimeScheduler

public class GlobalTaskPoolScheduling
extends Object
implements TeeTimeScheduler, PipeScheduler, Thread.UncaughtExceptionHandler

This scheduling approach maintains a global, synchronized, prioritized task pool whose tasks are stages. Multiple threads access this task pool concurrently. At each moment in time, a particular stage is executed only by at most one thread. Thus, a stage in combination with the task data structure acts as a lock for executing that stage.

Since:

3.0

Author:

Christian Wulf (chw)

Constructor Summary

Constructors

Constructor and Description
GlobalTaskPoolScheduling(int numThreads, Configuration configuration) A thread executes a stage x per job.
GlobalTaskPoolScheduling(int numThreads, Configuration configuration, int numOfExecutions)

Method Summary

Modifier and Type	Method and Description
List<AbstractStage>	getFiniteProducerStages()
Set<AbstractStage>	getFrontStages()
teetime.framework.scheduling.globaltaskpool.TeeTimeTaskQueueThreadChw	getOwningThreadSynched(AbstractStage stage)
teetime.framework.scheduling.globaltaskpool.PrioritizedTaskPool	getPrioritizedTaskPool()
boolean	isBeingExecuted(AbstractStage stage)
boolean	isPausedStage(AbstractStage stage)
void	onElementAdded(AbstractSynchedPipe<?> pipe) This event is invoked by the given synchronized pipe whenever a new element was added to it.
void	onElementAdded(AbstractUnsynchedPipe<?> pipe) This event is invoked by the given unsynchronized pipe whenever a new element was added to it.
void	onElementNotAdded(AbstractSynchedPipe<?> pipe) This event is invoked by the given synchronized pipe whenever a new element could not be added to it.
void	onExecute() Executes the execution.
void	onFinish() Waits for the execution to finished.
void	onInitialize()
void	onTerminate() Aborts the execution.
void	onValidate()
boolean	setIsBeingExecuted(AbstractStage stage, boolean newValue)
void	setOwningThreadSynced(AbstractStage stage, teetime.framework.scheduling.globaltaskpool.TeeTimeTaskQueueThreadChw newThread)
void	startStageAtRuntime(AbstractStage stage)
String	toString()
void	uncaughtException(Thread thread, Throwable throwable)

Methods inherited from class java.lang.Object

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

Constructor Detail

GlobalTaskPoolScheduling

public GlobalTaskPoolScheduling(int numThreads,
                                Configuration configuration)

A thread executes a stage x per job.

Parameters:

numThreads -

configuration -

GlobalTaskPoolScheduling

public GlobalTaskPoolScheduling(int numThreads,
                                Configuration configuration,
                                int numOfExecutions)

Parameters:

numThreads - the number of threads to use for executing the given P&F configuration

configuration - the configuration to execute/schedule

numOfExecutions - the number of execution per scheduled stage (task) for a thread. Is rounded up to the next power of 2, i.e., 1,2,4,16,...

Method Detail

onInitialize

public void onInitialize()

Specified by:

onInitialize in interface TeeTimeScheduler

onValidate

public void onValidate()

Specified by:

onValidate in interface TeeTimeScheduler

onExecute

public void onExecute()

Description copied from interface: TeeTimeScheduler

Executes the execution.

Specified by:

onExecute in interface TeeTimeScheduler

onTerminate

public void onTerminate()

Description copied from interface: TeeTimeScheduler

Aborts the execution.

Specified by:

onTerminate in interface TeeTimeScheduler

onFinish

public void onFinish()

Description copied from interface: TeeTimeScheduler

Waits for the execution to finished.

Specified by:

onFinish in interface TeeTimeScheduler

startStageAtRuntime

public void startStageAtRuntime(AbstractStage stage)

Specified by:

startStageAtRuntime in interface TeeTimeScheduler

getFiniteProducerStages

public List<AbstractStage> getFiniteProducerStages()

getFrontStages

public Set<AbstractStage> getFrontStages()

Returns:

a thread-safe set

getPrioritizedTaskPool

public teetime.framework.scheduling.globaltaskpool.PrioritizedTaskPool getPrioritizedTaskPool()

onElementAdded

public void onElementAdded(AbstractUnsynchedPipe<?> pipe)

Description copied from interface: PipeScheduler

This event is invoked by the given unsynchronized pipe whenever a new element was added to it.

Specified by:

onElementAdded in interface PipeScheduler

onElementAdded

public void onElementAdded(AbstractSynchedPipe<?> pipe)

Description copied from interface: PipeScheduler

This event is invoked by the given synchronized pipe whenever a new element was added to it.

Specified by:

onElementAdded in interface PipeScheduler

onElementNotAdded

public void onElementNotAdded(AbstractSynchedPipe<?> pipe)

Description copied from interface: PipeScheduler

This event is invoked by the given synchronized pipe whenever a new element could not be added to it.

Specified by:

onElementNotAdded in interface PipeScheduler

isPausedStage

public boolean isPausedStage(AbstractStage stage)

isBeingExecuted

public boolean isBeingExecuted(AbstractStage stage)

setIsBeingExecuted

public boolean setIsBeingExecuted(AbstractStage stage,
                                  boolean newValue)

setOwningThreadSynced

public void setOwningThreadSynced(AbstractStage stage,
                                  teetime.framework.scheduling.globaltaskpool.TeeTimeTaskQueueThreadChw newThread)

getOwningThreadSynched

public teetime.framework.scheduling.globaltaskpool.TeeTimeTaskQueueThreadChw getOwningThreadSynched(AbstractStage stage)

uncaughtException

public void uncaughtException(Thread thread,
                              Throwable throwable)

Specified by:

uncaughtException in interface Thread.UncaughtExceptionHandler

toString

public String toString()

Overrides:

toString in class Object