io.sarl.sre.janus.boot.configs.subconfigs
Class ExecutorsConfig
@org.eclipse.xtext.xbase.lib.XbaseGenerated
class ExecutorsConfig
extends java.lang.Object
Configuration for the parallel executors.
Maven Group Identifier:
io.sarl.sre.janus
Maven Artifact Identifier:
janus.kernel
Since:
0.8
Property Summary
Modifier and type Property and description
Level internalErrorVerboseLevel
Replies the verbosity level of the internal errors.
int keepAliveDuration
int maxThreads
Replies the maximum number of threads that could be used by the executor service.
int minThreads
int timeout
Field Summary
Modifier and type Field and description
public static val java.lang.String INTERNAL_ERROR_VERBOSE_LEVEL_NAME
Name of the property for the default verbosity level of the executor's internal errors.
public static val Level INTERNAL_ERROR_VERBOSE_LEVEL_VALUE
The default verbosity level of the executor's internal errors.
public static val java.lang.String MAP_TO_AVAILABLE_PROCESSORS_NAME
Name of the flag for the fact to map the number of threads of the executor service to the number of available processors.
public static val boolean MAP_TO_AVAILABLE_PROCESSORS_VALUE
Default activation flag for the fact to map the number of threads of the executor service to the number of available processors.
public static val java.lang.String MAX_NUMBER_OF_THREADS_IN_EXECUTOR_NAME
Name of property for the maximal number of threads to keep in the pool.
public static val int MAX_NUMBER_OF_THREADS_IN_EXECUTOR_VALUE
Indicates the maximal number of threads to keep in the pool.
public static val java.lang.String MIN_NUMBER_OF_THREADS_IN_EXECUTOR_NAME
Name of the property for the minimal number of threads to keep in the pool, even if they are idle.
public static val int MIN_NUMBER_OF_THREADS_IN_EXECUTOR_VALUE
Indicates the minimal number of threads to keep in the pool, even if they are idle.
public static val java.lang.String PERIODIC_THREAD_POOL_PURGE_NAME
Name of the property that indicates if the executor service is purging the thread queues periodically.
public static val boolean PERIODIC_THREAD_POOL_PURGE_VALUE
The default flag that indicates if the executor service is purging the thread queues periodically.
public static val java.lang.String PREFIX
Prefix for the configuration entries of the parallel execution configuration.
public static val java.lang.String THREAD_KEEP_ALIVE_DURATION_NAME
Name of the property for the duration for keeping the iddle threads alive (in seconds).
public static val int THREAD_KEEP_ALIVE_DURATION_VALUE
Indicates the duration for keeping the iddle threads alive (in seconds).
public static val java.lang.String THREAD_TIMEOUT_NAME
Name of the property for the numbers of seconds that the kernel is waiting for thread terminations before timeout.
public static val int THREAD_TIMEOUT_VALUE
Indicates the numbers of seconds that the kernel is waiting for thread terminations before timeout.
Action Summary
Modifier and type Action and description
Level getInternalErrorVerboseLevel
Replies the verbosity level of the internal errors.
int getKeepAliveDuration
int getMaxThreads
Replies the maximum number of threads that could be used by the executor service.
int getMinThreads
int getTimeout
boolean hasMaxThreadsSpecified
Replies if the maximum number of threads is specified.
boolean isMapToAvailableProcessors
boolean isPeriodicThreadPoolPurge
void setInternalErrorVerboseLevel(Level)
Change the verbosity level of the internal errors.
int setKeepAliveDuration(int)
Change the duration during which a thread is still in memory without being used for another task.
void setMapToAvailableProcessors(boolean)
Change the flag that indicates if the executor service must be mapped to the available processors.
void setMaxThreads(int)
Change the maximum number of threads that could be used by the executor service.
int setMinThreads(int)
Change the minimum number of threads that could be used by the executor service.
void setPeriodicThreadPoolPurge(boolean)
Change the verbosity level of the internal errors.
void setRendezvousTaskQueue(boolean)
Change the flag that indicates if the task queue of the executor service is implementing a rendez-vous between the thread that is submitting the task and the thread that is running the task.
int setTimeout(int)
Change the timeout duration for waiting the termination of the threads.
Property Details
internalErrorVerboseLevel 
var internalErrorVerboseLevel : Level
Replies the verbosity level of the internal errors.

This property is an alias for the action: getInternalErrorVerboseLevel

Returns:
the verbose level
keepAliveDuration 
val keepAliveDuration : int

This property is an alias for the action: getKeepAliveDuration

maxThreads 
var maxThreads : int
Replies the maximum number of threads that could be used by the executor service.

This property is an alias for the action: getMaxThreads

Returns:
the max number.
minThreads 
val minThreads : int

This property is an alias for the action: getMinThreads

timeout 
val timeout : int

This property is an alias for the action: getTimeout

Field Details
INTERNAL_ERROR_VERBOSE_LEVEL_NAME 
public static val INTERNAL_ERROR_VERBOSE_LEVEL_NAME : java.lang.String = "sre.services.executors.internalErrorVerboseLevel"
Name of the property for the default verbosity level of the executor's internal errors.
See:
INTERNAL_ERROR_VERBOSE_LEVEL_VALUE
INTERNAL_ERROR_VERBOSE_LEVEL_VALUE 
public static val INTERNAL_ERROR_VERBOSE_LEVEL_VALUE : Level
The default verbosity level of the executor's internal errors.
See:
INTERNAL_ERROR_VERBOSE_LEVEL_NAME
MAP_TO_AVAILABLE_PROCESSORS_NAME 
public static val MAP_TO_AVAILABLE_PROCESSORS_NAME : java.lang.String = "sre.services.executors.mapToAvailableProcessors"
Name of the flag for the fact to map the number of threads of the executor service to the number of available processors.
Since:
0.14
See:
MAP_TO_AVAILABLE_PROCESSORS_VALUE
MAP_TO_AVAILABLE_PROCESSORS_VALUE 
public static val MAP_TO_AVAILABLE_PROCESSORS_VALUE : boolean = false
Default activation flag for the fact to map the number of threads of the executor service to the number of available processors.
Since:
0.14
See:
MAP_TO_AVAILABLE_PROCESSORS_NAME
MAX_NUMBER_OF_THREADS_IN_EXECUTOR_NAME 
public static val MAX_NUMBER_OF_THREADS_IN_EXECUTOR_NAME : java.lang.String = "sre.services.executors.maxThreads"
Name of property for the maximal number of threads to keep in the pool.
See:
MAX_NUMBER_OF_THREADS_IN_EXECUTOR_VALUE
MAX_NUMBER_OF_THREADS_IN_EXECUTOR_VALUE 
public static val MAX_NUMBER_OF_THREADS_IN_EXECUTOR_VALUE : int = 512
Indicates the maximal number of threads to keep in the pool.
See:
MAX_NUMBER_OF_THREADS_IN_EXECUTOR_NAME
MIN_NUMBER_OF_THREADS_IN_EXECUTOR_NAME 
public static val MIN_NUMBER_OF_THREADS_IN_EXECUTOR_NAME : java.lang.String = "sre.services.executors.minThreads"
Name of the property for the minimal number of threads to keep in the pool, even if they are idle.
See:
MIN_NUMBER_OF_THREADS_IN_EXECUTOR_VALUE
MIN_NUMBER_OF_THREADS_IN_EXECUTOR_VALUE 
public static val MIN_NUMBER_OF_THREADS_IN_EXECUTOR_VALUE : int = 1
Indicates the minimal number of threads to keep in the pool, even if they are idle.
See:
MIN_NUMBER_OF_THREADS_IN_EXECUTOR_NAME
PERIODIC_THREAD_POOL_PURGE_NAME 
public static val PERIODIC_THREAD_POOL_PURGE_NAME : java.lang.String = "sre.services.executors.periodicThreadPoolPurge"
Name of the property that indicates if the executor service is purging the thread queues periodically.
Since:
0.11
See:
PERIODIC_THREAD_POOL_PURGE_VALUE
PERIODIC_THREAD_POOL_PURGE_VALUE 
public static val PERIODIC_THREAD_POOL_PURGE_VALUE : boolean = true
The default flag that indicates if the executor service is purging the thread queues periodically.
Since:
0.11
See:
PERIODIC_THREAD_POOL_PURGE_NAME
PREFIX 
public static val PREFIX : java.lang.String = "sre.services.executors"
Prefix for the configuration entries of the parallel execution configuration.
THREAD_KEEP_ALIVE_DURATION_NAME 
public static val THREAD_KEEP_ALIVE_DURATION_NAME : java.lang.String = "sre.services.executors.keepAliveDuration"
Name of the property for the duration for keeping the iddle threads alive (in seconds).
Since:
0.5.0
See:
THREAD_KEEP_ALIVE_DURATION_VALUE
THREAD_KEEP_ALIVE_DURATION_VALUE 
public static val THREAD_KEEP_ALIVE_DURATION_VALUE : int = 60
Indicates the duration for keeping the iddle threads alive (in seconds).
Since:
0.5.0
See:
THREAD_KEEP_ALIVE_DURATION_NAME
THREAD_TIMEOUT_NAME 
public static val THREAD_TIMEOUT_NAME : java.lang.String = "sre.services.executors.threadTimeout"
Name of the property for the numbers of seconds that the kernel is waiting for thread terminations before timeout.
See:
THREAD_TIMEOUT_VALUE
THREAD_TIMEOUT_VALUE 
public static val THREAD_TIMEOUT_VALUE : int = 30
Indicates the numbers of seconds that the kernel is waiting for thread terminations before timeout.
See:
THREAD_TIMEOUT_NAME
Action Details
getInternalErrorVerboseLevel 
def getInternalErrorVerboseLevel : Level
Replies the verbosity level of the internal errors.
Returns:
the verbose level
getKeepAliveDuration 
def getKeepAliveDuration : int
getMaxThreads 
def getMaxThreads : int
Replies the maximum number of threads that could be used by the executor service.
Returns:
the max number.
getMinThreads 
def getMinThreads : int
getTimeout 
def getTimeout : int
hasMaxThreadsSpecified 
def hasMaxThreadsSpecified : boolean
Replies if the maximum number of threads is specified.
Returns:
true if the maximum number of threads is specified. Otherwise false .
isMapToAvailableProcessors 
def isMapToAvailableProcessors : boolean
isPeriodicThreadPoolPurge 
def isPeriodicThreadPoolPurge : boolean
setInternalErrorVerboseLevel(Level) 
def setInternalErrorVerboseLevel(Level)
Change the verbosity level of the internal errors.
Parameters:
level - the verbose level.
setKeepAliveDuration(int) 
def setKeepAliveDuration(int) : int
Change the duration during which a thread is still in memory without being used for another task.
Parameters:
duration - the duration of an iddle thread.
setMapToAvailableProcessors(boolean) 
def setMapToAvailableProcessors(boolean)
Change the flag that indicates if the executor service must be mapped to the available processors.
Parameters:
enable - is true if the executor service maps the number of threads to the available processors.
Since:
0.14
setMaxThreads(int) 
def setMaxThreads(int)
Change the maximum number of threads that could be used by the executor service.
Parameters:
maxThreads - the max number.
setMinThreads(int) 
def setMinThreads(int) : int
Change the minimum number of threads that could be used by the executor service.
Parameters:
minThreads - the min number.
setPeriodicThreadPoolPurge(boolean) 
def setPeriodicThreadPoolPurge(boolean)
Change the verbosity level of the internal errors.
Parameters:
purge - indicates if the executor service is purging the thread pools periodically.
Since:
0.11
setRendezvousTaskQueue(boolean) 
def setRendezvousTaskQueue(boolean)
Change the flag that indicates if the task queue of the executor service is implementing a rendez-vous between the thread that is submitting the task and the thread that is running the task. In other words, a rendez-vous mechanism forces the submitting thread to wait for a thread that is able to run the task.
Parameters:
enableRendezVous - is true if the executor service must implements a rendez-vous between the threads
Since:
0.14
setTimeout(int) 
def setTimeout(int) : int
Change the timeout duration for waiting the termination of the threads.
Parameters:
duration - the timeout duration.