org.jboss.threads
Class JBossThreadPoolExecutor

java.lang.Object
  extended by java.util.concurrent.AbstractExecutorService
      extended by java.util.concurrent.ThreadPoolExecutor
          extended by 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


Copyright © 2011. All Rights Reserved.