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>

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

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
DefaultDexecutor(ExecutionEngine<T,R> executionEngine, TaskProvider<T,R> taskProvider)

Method Summary

Methods

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) Add Two dependent nodes into the graph, creating the nodes if not already present
void	addIndependent(T nodeValue) Add a node as independent, it does not require any dependent node
void	execute(ExecutionConfig config) Kicks off the execution of the nodes based on the dependency graph constructed, using addDepen*** apis
void	print(Writer writer) Prints the graph into the writer

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultDexecutor

public DefaultDexecutor(ExecutionEngine<T,R> executionEngine,
                TaskProvider<T,R> taskProvider)

DefaultDexecutor

public DefaultDexecutor(DexecutorConfig<T,R> config)

Creates the Executor with Config

Parameters:

config -

Method Detail

print

public void print(Writer writer)

Description copied from interface: Dexecutor

Prints the graph into the writer

Specified by:

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

addIndependent

public void addIndependent(T nodeValue)

Description copied from interface: Dexecutor

Add a node as independent, it does not require any dependent node

Specified by:

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

addDependency

public void addDependency(T evalFirstNode,
                 T evalLaterNode)

Description copied from interface: Dexecutor

Add Two dependent nodes into the graph, creating the nodes if not already present

evalFirstValue would be executed first and then evalAfterValue

Specified by:

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

addAsDependentOnAllLeafNodes

public void addAsDependentOnAllLeafNodes(T nodeValue)

Description copied from interface: Dexecutor

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 Dexecutor<T extends Comparable<T>>

addAsDependencyToAllInitialNodes

public void addAsDependencyToAllInitialNodes(T nodeValue)

Description copied from interface: Dexecutor

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 Dexecutor<T extends Comparable<T>>

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>>