public class InboundThreadPool extends ThreadPoolExecutor
ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy
Modifier and Type | Field and Description |
---|---|
static String |
IB_THREAD_CORE |
static String |
IB_THREAD_MAX |
static int |
INBOUND_CORE_THREADS |
static int |
INBOUND_KEEP_ALIVE |
static int |
INBOUND_MAX_THREADS |
static String |
INBOUND_THREAD_GROUP |
static String |
INBOUND_THREAD_ID_PREFIX |
static int |
INBOUND_THREAD_QLEN |
Constructor and Description |
---|
InboundThreadPool()
Default Constructor for the thread pool and will use all the values as default
|
InboundThreadPool(int corePoolSize,
int maxPoolSize,
long keepAliveTime,
int qlen,
String threadGroup,
String threadIdPrefix)
Constructor for the InboundThreadPool
|
InboundThreadPool(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue)
Constructor for the Inbound thread poll
|
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
invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor, submit, submit, submit
public static final int INBOUND_CORE_THREADS
public static final int INBOUND_MAX_THREADS
public static final int INBOUND_KEEP_ALIVE
public static final int INBOUND_THREAD_QLEN
public static final String INBOUND_THREAD_GROUP
public static final String INBOUND_THREAD_ID_PREFIX
public static final String IB_THREAD_CORE
public static final String IB_THREAD_MAX
public InboundThreadPool(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue)
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.public InboundThreadPool()
public InboundThreadPool(int corePoolSize, int maxPoolSize, long keepAliveTime, int qlen, String threadGroup, String threadIdPrefix)
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 prefixCopyright © 2005–2023 Apache Software Foundation. All rights reserved.