com.github.dexecutor.core

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

java.lang.Object

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

Type Parameters:

T - Type of Node/Task ID

R - Type of Node/Task result

public class DexecutorConfig<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
DexecutorConfig(ExecutionEngine<T,R> executor, TaskProvider<T,R> taskProvider) Construct the object with mandatory params, rest are optional
DexecutorConfig(ExecutorService executorService, TaskProvider<T,R> taskProvider) Construct the object with mandatory params, rest are optional

Method Summary

Methods

Modifier and Type	Method and Description
DexecutorState<T,R>	getDexecutorState()
int	getImmediateRetryPoolThreadsCount()
int	getScheduledRetryPoolThreadsCount()
void	setDexecutorState(DexecutorState<T,R> dexecutorState)
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

DexecutorConfig

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

Construct the object with mandatory params, rest are optional

Parameters:

executorService - @ExecutorService

taskProvider - @TaskProvider

DexecutorConfig

public DexecutorConfig(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 -

getDexecutorState

public DexecutorState<T,R> getDexecutorState()

setDexecutorState

public void setDexecutorState(DexecutorState<T,R> dexecutorState)