ds.granules.scheduler

Class TaskManagement

java.lang.Object

ds.granules.scheduler.TaskManagement

All Implemented Interfaces:

TaskLifecycleObserver, java.util.concurrent.RejectedExecutionHandler

public class TaskManagement
extends java.lang.Object
implements java.util.concurrent.RejectedExecutionHandler, TaskLifecycleObserver

This is the class that is responsible for managing tasks.

Author:

Shrideep Pallickara

Constructor Summary

Constructors

Constructor and Description
TaskManagement(int numberOfThreads, Diagnostics diagnostics)

Method Summary

Modifier and Type	Method and Description
void	abnormalOperationTermination(java.lang.String taskIdentifier, java.lang.String reason) Indicates that the task in question has terminated abnormally.
void	isChangedPeriodicExecution(java.lang.String taskIdentifier) Indicates that the task in question has changed it execution profile.
void	isComplete(java.lang.String taskIdentifier) Indicates that the task in question has finished processing.
void	isExecuting(java.lang.String taskIdentifier) Indicates that the task in question has been scheduled for execution and is currently executing.
void	isInitializing(java.lang.String taskIdentifier) Indicates that the task is question is currently performing initialization related operations.
void	isReady(java.lang.String taskIdentifier) When a task is ready for execution, this method is invoked on its registered observer.
void	isWaitingForData(java.lang.String taskIdentifier) Indicates that the task in question is waiting for the arrival of data to begin processing.
void	manageExecution(java.lang.String taskIdentifier, Operation operation) Manage the execution of the given operation
void	rejectedExecution(java.lang.Runnable r, java.util.concurrent.ThreadPoolExecutor inExecutor)

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskManagement

public TaskManagement(int numberOfThreads,
                      Diagnostics diagnostics)

Method Detail

rejectedExecution

public void rejectedExecution(java.lang.Runnable r,
                              java.util.concurrent.ThreadPoolExecutor inExecutor)

Specified by:

rejectedExecution in interface java.util.concurrent.RejectedExecutionHandler

abnormalOperationTermination

public void abnormalOperationTermination(java.lang.String taskIdentifier,
                                         java.lang.String reason)

Description copied from interface: TaskLifecycleObserver

Indicates that the task in question has terminated abnormally. Typically, this happens when a error is reported by the execute() method of the Operation.

Specified by:

abnormalOperationTermination in interface TaskLifecycleObserver

Parameters:

taskIdentifier - The identifier of the Task whose life cycle transition is being reported on.

reason - A description of the cause of the error.

manageExecution

public void manageExecution(java.lang.String taskIdentifier,
                            Operation operation)
                     throws ProcessingException,
                            DatasetException,
                            SchedulingException

Manage the execution of the given operation

Parameters:

taskIdentifier - The identifier of the task being started up.

operation - The operation that needs to be submitted for execution

Throws:

ProcessingException - If there are problems initializing the operation

DatasetException - If there are problems in accessing the underling dataset

SchedulingException - If there are problems in scheduling the operation

isComplete

public void isComplete(java.lang.String taskIdentifier)

Description copied from interface: TaskLifecycleObserver

Indicates that the task in question has finished processing.

Specified by:

isComplete in interface TaskLifecycleObserver

Parameters:

taskIdentifier - The identifier of the Task whose life cycle transition is being reported on.

isExecuting

public void isExecuting(java.lang.String taskIdentifier)

Description copied from interface: TaskLifecycleObserver

Indicates that the task in question has been scheduled for execution and is currently executing.

Specified by:

isExecuting in interface TaskLifecycleObserver

Parameters:

taskIdentifier - The identifier of the Task whose life cycle transition is being reported on.

isInitializing

public void isInitializing(java.lang.String taskIdentifier)

Description copied from interface: TaskLifecycleObserver

Indicates that the task is question is currently performing initialization related operations.

Specified by:

isInitializing in interface TaskLifecycleObserver

Parameters:

taskIdentifier - The identifier of the Task whose life cycle transition is being reported on.

isReady

public void isReady(java.lang.String taskIdentifier)

Description copied from interface: TaskLifecycleObserver

When a task is ready for execution, this method is invoked on its registered observer.

Specified by:

isReady in interface TaskLifecycleObserver

Parameters:

taskIdentifier - The identifier of the Task whose life cycle transition is being reported on.

isWaitingForData

public void isWaitingForData(java.lang.String taskIdentifier)

Description copied from interface: TaskLifecycleObserver

Indicates that the task in question is waiting for the arrival of data to begin processing.

Specified by:

isWaitingForData in interface TaskLifecycleObserver

Parameters:

taskIdentifier - The identifier of the Task whose life cycle transition is being reported on.

isChangedPeriodicExecution

public void isChangedPeriodicExecution(java.lang.String taskIdentifier)

Description copied from interface: TaskLifecycleObserver

Indicates that the task in question has changed it execution profile. This could be a changed in the execution interval for periodic execution, or it could be a change from periodic execution to one that is no-periodic.

Specified by:

isChangedPeriodicExecution in interface TaskLifecycleObserver

Parameters:

taskIdentifier - The identifier of the Task whose life cycle transition is being reported on.