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 DexecutorState and Validator

Author:

Nadeem Mohammad

Constructor Summary

Constructors

Constructor and Description
DexecutorConfig(ExecutionEngine<T,R> executionEngine, 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

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	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 - provided executor service

taskProvider - provided task provider

DexecutorConfig

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

Construct the object with mandatory params, rest are optional

Parameters:

executionEngine - provided execution Engine

taskProvider - provided task provider

Method Detail

setValidator

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

change the validator to that of specified

Parameters:

validator - the validator

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 - Number of threads that should process retry immediately

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 - Number of threads that should process retry immediately

getDexecutorState

public DexecutorState<T,R> getDexecutorState()

Returns:

the dexecutor state

setDexecutorState

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

Parameters:

dexecutorState - to set to