com.github.dexecutor.core

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

java.lang.Object

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

Type Parameters:

T - Type of Node/Task ID

R - Type of Node/Task result

public class DependentTasksExecutorConfig<T extends Comparable<T>,R>
extends Object

Configuration Object for Dexecutor framework. At a minimum it needs ExecutorService and TaskProvider, rest are optional and takes default values

This provides way to hook in your own Validator and Traversar

Author:

Nadeem Mohammad

Constructor Summary

Constructors

Constructor and Description
DependentTasksExecutorConfig(ExecutionEngine<T,R> executor, TaskProvider<T,R> taskProvider) Construct the object with mandatory params, rest are optional
DependentTasksExecutorConfig(ExecutorService executorService, TaskProvider<T,R> taskProvider) Construct the object with mandatory params, rest are optional

Method Summary

Methods

Modifier and Type	Method and Description
int	getImmediateRetryPoolThreadsCount()
int	getScheduledRetryPoolThreadsCount()
void	setImmediateRetryPoolThreadsCount(int immediateRetryPoolThreadsCount) sets the immediate retry thread pool size to that of specified
void	setScheduledRetryPoolThreadsCount(int scheduledRetryPoolThreadsCount) sets the scheduled thread pool size to that of specified
void	setTraversar(Traversar<T,R> traversar) Change the traversar to that of specified
void	setValidator(Validator<T,R> validator) change the validator to that of specified

Methods inherited from class java.lang.Object

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

Constructor Detail

DependentTasksExecutorConfig

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

Construct the object with mandatory params, rest are optional

Parameters:

executorService - @ExecutorService

taskProvider - @TaskProvider

DependentTasksExecutorConfig

public DependentTasksExecutorConfig(ExecutionEngine<T,R> executor,
                            TaskProvider<T,R> taskProvider)

Construct the object with mandatory params, rest are optional

Parameters:

executor - @ExecutionEngine

taskProvider - @TaskProvider

Method Detail

setValidator

public void setValidator(Validator<T,R> validator)

change the validator to that of specified

Parameters:

validator -

setTraversar

public void setTraversar(Traversar<T,R> traversar)

Change the traversar to that of specified

Parameters:

traversar -

getImmediateRetryPoolThreadsCount

public int getImmediateRetryPoolThreadsCount()

Returns:

the immediate retry thread pool count

setImmediateRetryPoolThreadsCount

public void setImmediateRetryPoolThreadsCount(int immediateRetryPoolThreadsCount)

sets the immediate retry thread pool size to that of specified

Parameters:

immediateRetryPoolThreadsCount -

getScheduledRetryPoolThreadsCount

public int getScheduledRetryPoolThreadsCount()

Returns:

the scheduled retry thread pool size

setScheduledRetryPoolThreadsCount

public void setScheduledRetryPoolThreadsCount(int scheduledRetryPoolThreadsCount)

sets the scheduled thread pool size to that of specified

Parameters:

scheduledRetryPoolThreadsCount -