com.bstek.dorado.view.task

Class DefaultTaskScheduler

java.lang.Object

com.bstek.dorado.view.task.DefaultTaskScheduler

All Implemented Interfaces:

TaskScheduler, TaskThreadExecutionListener

public class DefaultTaskScheduler
extends java.lang.Object
implements TaskScheduler, TaskThreadExecutionListener

Since:

2014-1-25

Author:

Benny Bao (mailto:benny.bao@bstek.com)

Constructor Summary

Constructors

Constructor and Description
DefaultTaskScheduler()

Method Summary

Methods

Modifier and Type	Method and Description
boolean	dequeueTask(LongTaskThread taskThread)
java.util.Set<LongTaskThread>	getRunningTasks()
java.util.Set<LongTaskThread>	getWaitingTasks()
void	onAbort(LongTaskThread taskThread)
void	onFailure(LongTaskThread taskThread, java.lang.Exception e)
void	onSuccess(LongTaskThread taskThread, java.lang.Object result)
protected void	onTaskTernimate(LongTaskThread taskThread)
void	queueTask(LongTaskThread taskThread)
void	setTaskDefinition(LongTaskDefinition taskDefinition)
protected void	startTask(LongTaskThread taskThread)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultTaskScheduler

public DefaultTaskScheduler()

Method Detail

setTaskDefinition

public void setTaskDefinition(LongTaskDefinition taskDefinition)

Specified by:

setTaskDefinition in interface TaskScheduler

startTask

protected void startTask(LongTaskThread taskThread)

queueTask

public void queueTask(LongTaskThread taskThread)

Specified by:

queueTask in interface TaskScheduler

dequeueTask

public boolean dequeueTask(LongTaskThread taskThread)

Specified by:

dequeueTask in interface TaskScheduler

getRunningTasks

public java.util.Set<LongTaskThread> getRunningTasks()

Specified by:

getRunningTasks in interface TaskScheduler

getWaitingTasks

public java.util.Set<LongTaskThread> getWaitingTasks()

Specified by:

getWaitingTasks in interface TaskScheduler

onTaskTernimate

protected void onTaskTernimate(LongTaskThread taskThread)

onSuccess

public void onSuccess(LongTaskThread taskThread,
             java.lang.Object result)

Specified by:

onSuccess in interface TaskThreadExecutionListener

onFailure

public void onFailure(LongTaskThread taskThread,
             java.lang.Exception e)

Specified by:

onFailure in interface TaskThreadExecutionListener

onAbort

public void onAbort(LongTaskThread taskThread)

Specified by:

onAbort in interface TaskThreadExecutionListener