Class SynapseThreadPool
- java.lang.Object
-
- java.util.concurrent.AbstractExecutorService
-
- java.util.concurrent.ThreadPoolExecutor
-
- org.apache.synapse.util.concurrent.SynapseThreadPool
-
- All Implemented Interfaces:
Executor
,ExecutorService
public class SynapseThreadPool extends ThreadPoolExecutor
This is the executor service that will be returned by the env
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor
ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy
-
-
Field Summary
Fields Modifier and Type Field Description static String
SYN_THREAD_ALIVE
static String
SYN_THREAD_CORE
static String
SYN_THREAD_GROUP
static String
SYN_THREAD_IDPREFIX
static String
SYN_THREAD_MAX
static String
SYN_THREAD_QLEN
static int
SYNAPSE_CORE_THREADS
static int
SYNAPSE_KEEP_ALIVE
static int
SYNAPSE_MAX_THREADS
static String
SYNAPSE_THREAD_GROUP
static String
SYNAPSE_THREAD_ID_PREFIX
static int
SYNAPSE_THREAD_QLEN
-
Constructor Summary
Constructors Constructor Description SynapseThreadPool()
Default Constructor for the thread pool and will use all the values as defaultSynapseThreadPool(int corePoolSize, int maxPoolSize, long keepAliveTime, int qlen, String threadGroup, String threadIdPrefix)
Constructor for the SynapseThreadPoolSynapseThreadPool(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue)
Constructor for the Synapse thread poll
-
Method Summary
-
Methods inherited from class java.util.concurrent.ThreadPoolExecutor
afterExecute, allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, execute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getQueue, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, shutdown, shutdownNow, terminated, toString
-
Methods inherited from class java.util.concurrent.AbstractExecutorService
invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor, submit, submit, submit
-
-
-
-
Field Detail
-
SYNAPSE_CORE_THREADS
public static final int SYNAPSE_CORE_THREADS
- See Also:
- Constant Field Values
-
SYNAPSE_MAX_THREADS
public static final int SYNAPSE_MAX_THREADS
- See Also:
- Constant Field Values
-
SYNAPSE_KEEP_ALIVE
public static final int SYNAPSE_KEEP_ALIVE
- See Also:
- Constant Field Values
-
SYNAPSE_THREAD_QLEN
public static final int SYNAPSE_THREAD_QLEN
- See Also:
- Constant Field Values
-
SYNAPSE_THREAD_GROUP
public static final String SYNAPSE_THREAD_GROUP
- See Also:
- Constant Field Values
-
SYNAPSE_THREAD_ID_PREFIX
public static final String SYNAPSE_THREAD_ID_PREFIX
- See Also:
- Constant Field Values
-
SYN_THREAD_CORE
public static final String SYN_THREAD_CORE
- See Also:
- Constant Field Values
-
SYN_THREAD_MAX
public static final String SYN_THREAD_MAX
- See Also:
- Constant Field Values
-
SYN_THREAD_ALIVE
public static final String SYN_THREAD_ALIVE
- See Also:
- Constant Field Values
-
SYN_THREAD_QLEN
public static final String SYN_THREAD_QLEN
- See Also:
- Constant Field Values
-
SYN_THREAD_GROUP
public static final String SYN_THREAD_GROUP
- See Also:
- Constant Field Values
-
SYN_THREAD_IDPREFIX
public static final String SYN_THREAD_IDPREFIX
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
SynapseThreadPool
public SynapseThreadPool(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue)
Constructor for the Synapse thread poll- Parameters:
corePoolSize
- - number of threads to keep in the pool, even if they are idlemaximumPoolSize
- - the maximum number of threads to allow in the poolkeepAliveTime
- - this is the maximum time that excess idle threads will wait for new tasks before terminating.unit
- - the time unit for the keepAliveTime argument.workQueue
- - the queue to use for holding tasks before they are executed.
-
SynapseThreadPool
public SynapseThreadPool()
Default Constructor for the thread pool and will use all the values as default
-
SynapseThreadPool
public SynapseThreadPool(int corePoolSize, int maxPoolSize, long keepAliveTime, int qlen, String threadGroup, String threadIdPrefix)
Constructor for the SynapseThreadPool- Parameters:
corePoolSize
- - number of threads to keep in the pool, even if they are idlemaxPoolSize
- - the maximum number of threads to allow in the poolkeepAliveTime
- - this is the maximum time that excess idle threads will wait for new tasks before terminating.qlen
- - Thread Blocking Queue lengththreadGroup
- - ThreadGroup namethreadIdPrefix
- - Thread id prefix
-
-