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 Class Summary

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)

Method Summary

void	destroy()
int	getCurrentPoolSize()
long	getKeepAliveTime()
int	getMaxPoolSize()
java.lang.String	getName()
int	getRejectedCount()
java.util.concurrent.RejectedExecutionHandler	getRejectedExecutionHandler()
boolean	isAllowCoreThreadTimeout()
void	setAllowCoreThreadTimeout(boolean allow)
void	setKeepAliveTime(long milliseconds)
void	setMaxPoolSize(int newSize)
void	setRejectedExecutionHandler(java.util.concurrent.RejectedExecutionHandler handler)
void	stop()

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

Methods inherited from interface org.jboss.threads.ThreadPoolExecutorMBean

getCorePoolSize, getLargestPoolSize, setCorePoolSize

Constructor Detail

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)

Method Detail

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