com.github.dexecutor.core.task

Class Task<T,R>

java.lang.Object

com.github.dexecutor.core.task.Task<T,R>

Type Parameters:

T - Type of Node/Task ID

R - Type of Node/Task result

All Implemented Interfaces:

Serializable

public abstract class Task<T,R>
extends Object
implements Serializable

Represent a unit of execution in Dexecutor framework

Author:

Nadeem Mohammad

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Task()

Method Summary

Modifier and Type	Method and Description
abstract R	execute() Framework would call this method, when it comes for tasks to be executed.
LocalDateTime	getEndTime()
T	getId()
ExecutionResults<T,R>	getParentResults()
protected ExecutionResult<T,R>	getResult(T id)
LocalDateTime	getStartTime()
Duration	getTimeout()
boolean	isCompleted()
boolean	isTimedOut()
void	markEnd()
void	markStart()
void	setConsiderExecutionError(boolean considerExecutionError) sets whether execution errors should be considered or not?
void	setId(T id) Sets the new id
void	setNodeProvider(NodeProvider<T,R> nodeProvider)
void	setParentResults(ExecutionResults<T,R> parentResults) sets the parent results
boolean	shouldConsiderExecutionError()
boolean	shouldExecute(ExecutionResults<T,R> parentResults) Defines whether or not this task should be executed
ExecutionStatus	status(Node<T,R> node)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

Task

public Task()

Method Detail

setNodeProvider

public void setNodeProvider(NodeProvider<T,R> nodeProvider)

Parameters:

nodeProvider -

getResult

protected ExecutionResult<T,R> getResult(T id)

status

public ExecutionStatus status(Node<T,R> node)

setId

public void setId(T id)

Sets the new id

Parameters:

id - the task id

getId

public T getId()

Returns:

id of the task

getParentResults

public ExecutionResults<T,R> getParentResults()

Returns:

ExecutionResults

setParentResults

public void setParentResults(ExecutionResults<T,R> parentResults)

sets the parent results

Parameters:

parentResults -

execute

public abstract R execute()

Framework would call this method, when it comes for tasks to be executed.

Returns:

the result of task execution

shouldConsiderExecutionError

public boolean shouldConsiderExecutionError()

Returns:

whether execution error should be considered or not

setConsiderExecutionError

public void setConsiderExecutionError(boolean considerExecutionError)

sets whether execution errors should be considered or not?

Parameters:

considerExecutionError - the new value

shouldExecute

public boolean shouldExecute(ExecutionResults<T,R> parentResults)

Defines whether or not this task should be executed

Parameters:

parentResults - parent execution results

Returns:

true If this task should be executed false If the task should be skipped

markStart

public void markStart()

getStartTime

public LocalDateTime getStartTime()

markEnd

public void markEnd()

getEndTime

public LocalDateTime getEndTime()

isCompleted

public boolean isCompleted()

getTimeout

public Duration getTimeout()

isTimedOut

public boolean isTimedOut()

toString

public String toString()

Overrides:

toString in class Object