public class InboundThreadPool
extends java.util.concurrent.ThreadPoolExecutor
java.util.concurrent.ThreadPoolExecutor.AbortPolicy, java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardOldestPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardPolicy
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
IB_THREAD_CORE |
static java.lang.String |
IB_THREAD_MAX |
static int |
INBOUND_CORE_THREADS |
static int |
INBOUND_KEEP_ALIVE |
static int |
INBOUND_MAX_THREADS |
static java.lang.String |
INBOUND_THREAD_GROUP |
static java.lang.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,
java.lang.String threadGroup,
java.lang.String threadIdPrefix)
Constructor for the InboundThreadPool
|
InboundThreadPool(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
java.util.concurrent.TimeUnit unit,
java.util.concurrent.BlockingQueue<java.lang.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
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 java.lang.String INBOUND_THREAD_GROUP
public static final java.lang.String INBOUND_THREAD_ID_PREFIX
public static final java.lang.String IB_THREAD_CORE
public static final java.lang.String IB_THREAD_MAX
public InboundThreadPool(int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.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, java.lang.String threadGroup, java.lang.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-2022 Apache Software Foundation. All Rights Reserved.