final class ExecutorConfigurationImpl extends java.lang.Object implements ExecutorConfiguration
Modifier and Type | Class and Description |
---|---|
(package private) static class |
ExecutorConfigurationImpl.ConfigurationProperty |
Modifier and Type | Field and Description |
---|---|
private org.apache.commons.configuration.Configuration |
config |
private static boolean |
TASK_ALLOWCORETHREADTIMEOUT_DEFAULT
value = false
|
private static int |
TASK_AWAITTERMINATIONINMILLIS_DEFAULT
value = 1000
|
private static int |
TASK_COREPOOLSIZE_DEFAULT
value = 3
|
private static java.lang.String |
TASK_KEEPALIVE_TIMEUNIT_SECONDS_DEFAULT
value = SECONDS
|
private static int |
TASK_MAXIMUMKEEPALIVETIME_DEFAULT
value = 60
|
private static java.lang.String |
TASK_POOLNAME_DEFAULT
value = "EpTaskPool"
|
private static int |
TASK_QUEUECAPACITY_DEFAULT
value = 2147483647
|
private static java.util.concurrent.ThreadFactory |
THREAD_FACTORY |
Constructor and Description |
---|
ExecutorConfigurationImpl(org.apache.commons.configuration.Configuration config) |
Modifier and Type | Method and Description |
---|---|
int |
getAwaitTerminationInMillis() |
int |
getCorePoolSize() |
long |
getKeepAliveTime() |
java.util.concurrent.TimeUnit |
getKeepAliveTimeUnit() |
int |
getMaximumPoolSize() |
java.util.concurrent.RejectedExecutionHandler |
getRejectedExecutionHandler() |
java.util.concurrent.ThreadFactory |
getThreadFactory() |
java.util.concurrent.BlockingQueue<java.lang.Runnable> |
getWorkQueue() |
boolean |
isAllowCoreThreadTimeOut() |
private static final boolean TASK_ALLOWCORETHREADTIMEOUT_DEFAULT
private static final int TASK_QUEUECAPACITY_DEFAULT
private static final java.lang.String TASK_KEEPALIVE_TIMEUNIT_SECONDS_DEFAULT
private static final java.lang.String TASK_POOLNAME_DEFAULT
private static final int TASK_MAXIMUMKEEPALIVETIME_DEFAULT
private static final int TASK_COREPOOLSIZE_DEFAULT
private final org.apache.commons.configuration.Configuration config
private static final java.util.concurrent.ThreadFactory THREAD_FACTORY
private static final int TASK_AWAITTERMINATIONINMILLIS_DEFAULT
@Inject public ExecutorConfigurationImpl(org.apache.commons.configuration.Configuration config)
public int getCorePoolSize()
getCorePoolSize
in interface ExecutorConfiguration
ThreadPoolExecutor.getCorePoolSize()
public boolean isAllowCoreThreadTimeOut()
isAllowCoreThreadTimeOut
in interface ExecutorConfiguration
ThreadPoolExecutor.allowCoreThreadTimeOut(boolean)
public long getKeepAliveTime()
getKeepAliveTime
in interface ExecutorConfiguration
ThreadPoolExecutor.getKeepAliveTime(java.util.concurrent.TimeUnit)
public java.util.concurrent.TimeUnit getKeepAliveTimeUnit()
getKeepAliveTimeUnit
in interface ExecutorConfiguration
ThreadPoolExecutor.getKeepAliveTime(java.util.concurrent.TimeUnit)
public java.util.concurrent.BlockingQueue<java.lang.Runnable> getWorkQueue()
getWorkQueue
in interface ExecutorConfiguration
ThreadPoolExecutor.getThreadFactory()
public java.util.concurrent.RejectedExecutionHandler getRejectedExecutionHandler()
getRejectedExecutionHandler
in interface ExecutorConfiguration
ThreadPoolExecutor.getRejectedExecutionHandler()
public java.util.concurrent.ThreadFactory getThreadFactory()
getThreadFactory
in interface ExecutorConfiguration
ThreadPoolExecutor.getThreadFactory()
public int getAwaitTerminationInMillis()
getAwaitTerminationInMillis
in interface ExecutorConfiguration
public int getMaximumPoolSize()
getMaximumPoolSize
in interface ExecutorConfiguration
ThreadPoolExecutor.getMaximumPoolSize()