Class TimeKeeperObserver<T extends TaskTideModel<T>>

java.lang.Object

org.tasktide.engine.observer.worker.TimeKeeperObserver<T>

Type Parameters:

T - of TaskTideModel-WorkItem,ItemTask

All Implemented Interfaces:

WorkerObserver<T>, TaskTideWorkerUnit<T>

Direct Known Subclasses:

ItemTaskTimeKeeper, WorkItemTimeKeeper

public abstract class TimeKeeperObserver<T extends TaskTideModel<T>>
extends Object
implements WorkerObserver<T>

Time keeper observer for TaskTideWorkerUnit processing of WorkItem, and ItemTask

Field Summary

Fields

Modifier and Type	Field	Description
protected final AtomicBoolean	abort
protected final List<Long>	executionTimes
protected final org.apache.logging.log4j.Logger	logger
protected final AtomicLong	startTime

Constructor Summary

Constructors

Constructor	Description
TimeKeeperObserver(long maxTime, org.apache.logging.log4j.Logger logger)	Construct with max allowed time

Method Summary

Modifier and Type	Method	Description
ObserverType	getType()	Return ObserverType
abstract void	handleTaskState(T task, boolean flag)	Let sub-classes handle logic
boolean	isOptional()	Use ObserverType to check if TimeKeeper is optional.
ObserverResult	onTaskEnd(T task)	Evaluate whether the next task can run
ObserverResult	onTaskProcessing(T task)	Leaving out for now
ObserverResult	onTaskStart(T task)	Evaluate whether task can run before execution

Methods inherited from class Object

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

Methods inherited from interface WorkerObserver

getName

Field Details

logger

protected final org.apache.logging.log4j.Logger logger

startTime

protected final AtomicLong startTime

abort

protected final AtomicBoolean abort

executionTimes

protected final List<Long> executionTimes

Constructor Details

TimeKeeperObserver

public TimeKeeperObserver(long maxTime,
 org.apache.logging.log4j.Logger logger)

Construct with max allowed time

Parameters:

maxTime -

logger -

Method Details

isOptional

public boolean isOptional()

Use ObserverType to check if TimeKeeper is optional. If not optional there is a guard against the max time LTE 1

Specified by:

isOptional in interface WorkerObserver<T extends TaskTideModel<T>>

Returns:

boolean

getType

public ObserverType getType()

Return ObserverType

Specified by:

getType in interface WorkerObserver<T extends TaskTideModel<T>>

Returns:

ObserverType

onTaskStart

public ObserverResult onTaskStart(T task)

Evaluate whether task can run before execution

Specified by:

onTaskStart in interface WorkerObserver<T extends TaskTideModel<T>>

Parameters:

task -

Returns:

boolean

onTaskEnd

public ObserverResult onTaskEnd(T task)

Evaluate whether the next task can run

Specified by:

onTaskEnd in interface WorkerObserver<T extends TaskTideModel<T>>

Parameters:

task -

Returns:

boolean

onTaskProcessing

public ObserverResult onTaskProcessing(T task)

Leaving out for now

Specified by:

onTaskProcessing in interface WorkerObserver<T extends TaskTideModel<T>>

Parameters:

task -

Returns:

boolean

handleTaskState

public abstract void handleTaskState(T task,
 boolean flag)

Let sub-classes handle logic

Parameters:

task - - of WorkItem, ItemTask

flag -