com.github.dexecutor.executor

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

java.lang.Object

com.github.dexecutor.executor.DefaultDependentTasksExecutor<T,R>

Type Parameters:

T - Type of Node/Task ID

R - Type of Node/Task result

All Implemented Interfaces:

DependentTasksExecutor<T>

public final class DefaultDependentTasksExecutor<T extends Comparable<T>,R>
extends Object
implements DependentTasksExecutor<T>

Default implementation of @DependentTasksExecutor

Since:

0.0.1

Author:

Nadeem Mohammad

Nested Class Summary

Nested classes/interfaces inherited from interface com.github.dexecutor.executor.DependentTasksExecutor

DependentTasksExecutor.ExecutionBehavior

Constructor Summary

Constructors

Constructor and Description
DefaultDependentTasksExecutor(DependentTasksExecutorConfig<T,R> config) Creates the Executor with Config
DefaultDependentTasksExecutor(ExecutorService executorService, TaskProvider<T,R> taskProvider) Creates the Executor with bare minimum required params

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(DependentTasksExecutor.ExecutionBehavior behavior) 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
protected boolean	shouldRetry(T node)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultDependentTasksExecutor

public DefaultDependentTasksExecutor(ExecutorService executorService,
                             TaskProvider<T,R> taskProvider)

Creates the Executor with bare minimum required params

Parameters:

executorService -

taskProvider -

DefaultDependentTasksExecutor

public DefaultDependentTasksExecutor(DependentTasksExecutorConfig<T,R> config)

Creates the Executor with Config

Parameters:

config -

Method Detail

print

public void print(Writer writer)

Description copied from interface: DependentTasksExecutor

Prints the graph into the writer

Specified by:

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

addIndependent

public void addIndependent(T nodeValue)

Description copied from interface: DependentTasksExecutor

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

Specified by:

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

addDependency

public void addDependency(T evalFirstNode,
                 T evalLaterNode)

Description copied from interface: DependentTasksExecutor

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

addAsDependentOnAllLeafNodes

public void addAsDependentOnAllLeafNodes(T nodeValue)

Description copied from interface: DependentTasksExecutor

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

addAsDependencyToAllInitialNodes

public void addAsDependencyToAllInitialNodes(T nodeValue)

Description copied from interface: DependentTasksExecutor

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

execute

public void execute(DependentTasksExecutor.ExecutionBehavior behavior)

Description copied from interface: DependentTasksExecutor

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

Specified by:

execute in interface DependentTasksExecutor<T extends Comparable<T>>

shouldRetry

protected boolean shouldRetry(T node)