com.github.dexecutor.core

Class DefaultDexecutor<T extends Comparable<T>,R>

java.lang.Object

com.github.dexecutor.core.DefaultDexecutor<T,R>

Type Parameters:

T - Type of Node/Task ID

R - Type of Node/Task result

All Implemented Interfaces:

Dexecutor<T,R>, DependencyAware<T>

public class DefaultDexecutor<T extends Comparable<T>,R>
extends Object
implements Dexecutor<T,R>

Default implementation of @Dexecutor

Since:

0.0.1

Author:

Nadeem Mohammad

Constructor Summary

Constructors

Constructor and Description
DefaultDexecutor(DexecutorConfig<T,R> config) Creates the Executor with Config

Method Summary

Modifier and Type	Method and Description
void	addAsDependencyToAllInitialNodes(T nodeValue) Adds the node as dependency to all initial nodes (at the time of adding), meaning this given node would be evaluated first and then all initial nodes would run in parallel
void	addAsDependentOnAllLeafNodes(T nodeValue) Adds the node as dependent on all leaf nodes (at the time of adding), meaning all leaf nodes would be evaluated first and then the given node
void	addDependency(T evalFirstNode, T evalLaterNode) Should add the two nodes in the datastructure in such a way that evalFirstValue should be evaluated before evalAfterValue.
void	addIndependent(T nodeValue) Adds the given node to the datastructure whith out any dependency Nodes should be created only if it is not already added.
void	execute(ExecutionConfig config) Kicks off the execution of the nodes based on the dependency graph constructed, using addDepen*** apis
void	print(Traversar<T,R> traversar, TraversarAction<T,R> action) Prints the graph into the writer, using the traversar
void	recoverExecution(ExecutionConfig config) After a dexecutor crash, create a new instance of dexecutor and call this method for recovery
protected boolean	shouldContinueProcessingNodes() Override this method if force stop is required

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultDexecutor

public DefaultDexecutor(DexecutorConfig<T,R> config)

Creates the Executor with Config

Parameters:

config - based on which dexecutor would be constructed

Method Detail

print

public void print(Traversar<T,R> traversar,
                  TraversarAction<T,R> action)

Description copied from interface: Dexecutor

Prints the graph into the writer, using the traversar

Specified by:

print in interface Dexecutor<T extends Comparable<T>,R>

Parameters:

traversar - would traverse the graph

action - callback which would be called based on traverse

addIndependent

public void addIndependent(T nodeValue)

Description copied from interface: DependencyAware

Adds the given node to the datastructure whith out any dependency Nodes should be created only if it is not already added.

Specified by:

addIndependent in interface DependencyAware<T extends Comparable<T>>

Parameters:

nodeValue - Unique node id

addDependency

public void addDependency(T evalFirstNode,
                          T evalLaterNode)

Description copied from interface: DependencyAware

Should add the two nodes in the datastructure in such a way that evalFirstValue should be evaluated before evalAfterValue. Nodes should be created only if it is not already added.

Specified by:

addDependency in interface DependencyAware<T extends Comparable<T>>

Parameters:

evalFirstNode - Node which should be evaluated first

evalLaterNode - Node which should be evaluated after evalFirstValue

addAsDependentOnAllLeafNodes

public void addAsDependentOnAllLeafNodes(T nodeValue)

Description copied from interface: DependencyAware

Adds the node as dependent on all leaf nodes (at the time of adding), meaning all leaf nodes would be evaluated first and then the given node

Specified by:

addAsDependentOnAllLeafNodes in interface DependencyAware<T extends Comparable<T>>

Parameters:

nodeValue - Node which should depend on all leaf nodes

addAsDependencyToAllInitialNodes

public void addAsDependencyToAllInitialNodes(T nodeValue)

Description copied from interface: DependencyAware

Adds the node as dependency to all initial nodes (at the time of adding), meaning this given node would be evaluated first and then all initial nodes would run in parallel

Specified by:

addAsDependencyToAllInitialNodes in interface DependencyAware<T extends Comparable<T>>

Parameters:

nodeValue - Node on which all initial nodes should depends on

recoverExecution

public void recoverExecution(ExecutionConfig config)

Description copied from interface: Dexecutor

After a dexecutor crash, create a new instance of dexecutor and call this method for recovery

Specified by:

recoverExecution in interface Dexecutor<T extends Comparable<T>,R>

Parameters:

config - based on which execution would recover

execute

public void execute(ExecutionConfig config)

Description copied from interface: Dexecutor

Kicks off the execution of the nodes based on the dependency graph constructed, using addDepen*** apis

Specified by:

execute in interface Dexecutor<T extends Comparable<T>,R>

Parameters:

config - based on which execution should proceed.

shouldContinueProcessingNodes

protected boolean shouldContinueProcessingNodes()

Override this method if force stop is required

Returns:

true if processing should continue otherwise false