public class ActiveMQThreadPoolExecutor extends ThreadPoolExecutor
ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy
Constructor and Description |
---|
ActiveMQThreadPoolExecutor(int coreSize,
int maxSize,
long keep,
TimeUnit keepUnits,
ThreadFactory factory) |
Modifier and Type | Method and Description |
---|---|
protected void |
afterExecute(Runnable runnable,
Throwable throwable) |
protected void |
beforeExecute(Thread thread,
Runnable runnable) |
int |
getMaximumPoolSize() |
void |
setMaximumPoolSize(int maxSize) |
allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, execute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getPoolSize, getQueue, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setRejectedExecutionHandler, setThreadFactory, shutdown, shutdownNow, terminated, toString
invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor, submit, submit, submit
public ActiveMQThreadPoolExecutor(int coreSize, int maxSize, long keep, TimeUnit keepUnits, ThreadFactory factory)
public int getMaximumPoolSize()
getMaximumPoolSize
in class ThreadPoolExecutor
public void setMaximumPoolSize(int maxSize)
setMaximumPoolSize
in class ThreadPoolExecutor
protected void beforeExecute(Thread thread, Runnable runnable)
beforeExecute
in class ThreadPoolExecutor
protected void afterExecute(Runnable runnable, Throwable throwable)
afterExecute
in class ThreadPoolExecutor
Copyright © 2016 The Apache Software Foundation. All rights reserved.