org.jboss.threads
Class JBossThreadPoolExecutor
java.lang.Object
java.util.concurrent.AbstractExecutorService
java.util.concurrent.ThreadPoolExecutor
org.jboss.threads.JBossThreadPoolExecutor
- All Implemented Interfaces:
- java.util.concurrent.Executor, java.util.concurrent.ExecutorService, ThreadPoolExecutorMBean
public final class JBossThreadPoolExecutor
- extends java.util.concurrent.ThreadPoolExecutor
- implements ThreadPoolExecutorMBean
Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor |
java.util.concurrent.ThreadPoolExecutor.AbortPolicy, java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardOldestPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardPolicy |
Constructor Summary |
JBossThreadPoolExecutor(java.lang.String name,
int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
java.util.concurrent.TimeUnit unit,
java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue)
|
JBossThreadPoolExecutor(java.lang.String name,
int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
java.util.concurrent.TimeUnit unit,
java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
java.util.concurrent.RejectedExecutionHandler handler)
|
JBossThreadPoolExecutor(java.lang.String name,
int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
java.util.concurrent.TimeUnit unit,
java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
java.util.concurrent.ThreadFactory threadFactory)
|
JBossThreadPoolExecutor(java.lang.String name,
int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
java.util.concurrent.TimeUnit unit,
java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
java.util.concurrent.ThreadFactory threadFactory,
java.util.concurrent.RejectedExecutionHandler handler)
|
Methods inherited from class java.util.concurrent.ThreadPoolExecutor |
afterExecute, allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, execute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getQueue, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setThreadFactory, shutdown, shutdownNow, terminated |
Methods inherited from class java.util.concurrent.AbstractExecutorService |
invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor, submit, submit, submit |
Methods inherited from class java.lang.Object |
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JBossThreadPoolExecutor
public JBossThreadPoolExecutor(java.lang.String name,
int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
java.util.concurrent.TimeUnit unit,
java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue)
JBossThreadPoolExecutor
public JBossThreadPoolExecutor(java.lang.String name,
int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
java.util.concurrent.TimeUnit unit,
java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
java.util.concurrent.ThreadFactory threadFactory)
JBossThreadPoolExecutor
public JBossThreadPoolExecutor(java.lang.String name,
int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
java.util.concurrent.TimeUnit unit,
java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
java.util.concurrent.RejectedExecutionHandler handler)
JBossThreadPoolExecutor
public JBossThreadPoolExecutor(java.lang.String name,
int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
java.util.concurrent.TimeUnit unit,
java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
java.util.concurrent.ThreadFactory threadFactory,
java.util.concurrent.RejectedExecutionHandler handler)
stop
public void stop()
destroy
public void destroy()
getName
public java.lang.String getName()
- Specified by:
getName
in interface ThreadPoolExecutorMBean
isAllowCoreThreadTimeout
public boolean isAllowCoreThreadTimeout()
- Specified by:
isAllowCoreThreadTimeout
in interface ThreadPoolExecutorMBean
setAllowCoreThreadTimeout
public void setAllowCoreThreadTimeout(boolean allow)
- Specified by:
setAllowCoreThreadTimeout
in interface ThreadPoolExecutorMBean
getMaxPoolSize
public int getMaxPoolSize()
- Specified by:
getMaxPoolSize
in interface ThreadPoolExecutorMBean
setMaxPoolSize
public void setMaxPoolSize(int newSize)
- Specified by:
setMaxPoolSize
in interface ThreadPoolExecutorMBean
getKeepAliveTime
public long getKeepAliveTime()
- Specified by:
getKeepAliveTime
in interface ThreadPoolExecutorMBean
setKeepAliveTime
public void setKeepAliveTime(long milliseconds)
- Specified by:
setKeepAliveTime
in interface ThreadPoolExecutorMBean
getCurrentPoolSize
public int getCurrentPoolSize()
- Specified by:
getCurrentPoolSize
in interface ThreadPoolExecutorMBean
getRejectedCount
public int getRejectedCount()
- Specified by:
getRejectedCount
in interface ThreadPoolExecutorMBean
getRejectedExecutionHandler
public java.util.concurrent.RejectedExecutionHandler getRejectedExecutionHandler()
- Overrides:
getRejectedExecutionHandler
in class java.util.concurrent.ThreadPoolExecutor
setRejectedExecutionHandler
public void setRejectedExecutionHandler(java.util.concurrent.RejectedExecutionHandler handler)
- Overrides:
setRejectedExecutionHandler
in class java.util.concurrent.ThreadPoolExecutor
Copyright © 2011. All Rights Reserved.