org.apache.james.util.concurrent

Class JMXEnabledThreadPoolExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

org.apache.james.util.concurrent.JMXEnabledThreadPoolExecutor

All Implemented Interfaces:

Executor, ExecutorService, JMXEnabledThreadPoolExecutorMBean

public class JMXEnabledThreadPoolExecutor
extends ThreadPoolExecutor
implements JMXEnabledThreadPoolExecutorMBean

ThreadPoolExecutor which expose statistics via JMX

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor

ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy

Constructor Summary

Constructors

Constructor and Description
JMXEnabledThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> queue, NamedThreadFactory tFactory, String jmxPath)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	afterExecute(Runnable r, Throwable t)
protected void	beforeExecute(Thread t, Runnable r)
int	getActiveTasks() Return the active Tasks
int	getActiveThreads() Return the active threads
double	getAverageTaskTime() Return the average time for a task (in ms)
int	getMaximalThreads() Return the maximal allowed count of threads
int	getQueuedTasks() Return the queued tasks
int	getTotalTasks() Return the total tasks handled by this executor
static JMXEnabledThreadPoolExecutor	newCachedThreadPool(String jmxPath, NamedThreadFactory factory) Create a cached instance of this class.
static JMXEnabledThreadPoolExecutor	newCachedThreadPool(String jmxPath, String name) Create a cached instance of this class.
static JMXEnabledThreadPoolExecutor	newFixedThreadPool(String jmxPath, int nThreads, NamedThreadFactory threadFactory)
static JMXEnabledThreadPoolExecutor	newFixedThreadPool(String jmxPath, String name, int nThreads)
void	shutdown()
List<Runnable>	shutdownNow()

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, 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, terminated, toString

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, wait, wait, wait

Constructor Detail

JMXEnabledThreadPoolExecutor

public JMXEnabledThreadPoolExecutor(int corePoolSize,
                            int maximumPoolSize,
                            long keepAliveTime,
                            TimeUnit unit,
                            BlockingQueue<Runnable> queue,
                            NamedThreadFactory tFactory,
                            String jmxPath)

Method Detail

beforeExecute

protected void beforeExecute(Thread t,
                 Runnable r)

Overrides:

beforeExecute in class ThreadPoolExecutor

afterExecute

protected void afterExecute(Runnable r,
                Throwable t)

Overrides:

afterExecute in class ThreadPoolExecutor

shutdown

public void shutdown()

Specified by:

shutdown in interface ExecutorService

Overrides:

shutdown in class ThreadPoolExecutor

shutdownNow

public List<Runnable> shutdownNow()

Specified by:

shutdownNow in interface ExecutorService

Overrides:

shutdownNow in class ThreadPoolExecutor

getTotalTasks

public int getTotalTasks()

Description copied from interface: JMXEnabledThreadPoolExecutorMBean

Return the total tasks handled by this executor

Specified by:

getTotalTasks in interface JMXEnabledThreadPoolExecutorMBean

Returns:

tTasks

See Also:

JMXEnabledThreadPoolExecutorMBean.getTotalTasks()

getAverageTaskTime

public double getAverageTaskTime()

Description copied from interface: JMXEnabledThreadPoolExecutorMBean

Return the average time for a task (in ms)

Specified by:

getAverageTaskTime in interface JMXEnabledThreadPoolExecutorMBean

Returns:

aTime

See Also:

JMXEnabledThreadPoolExecutorMBean.getAverageTaskTime()

getActiveThreads

public int getActiveThreads()

Description copied from interface: JMXEnabledThreadPoolExecutorMBean

Return the active threads

Specified by:

getActiveThreads in interface JMXEnabledThreadPoolExecutorMBean

Returns:

aThreads

See Also:

JMXEnabledThreadPoolExecutorMBean.getActiveThreads()

getActiveTasks

public int getActiveTasks()

Description copied from interface: JMXEnabledThreadPoolExecutorMBean

Return the active Tasks

Specified by:

getActiveTasks in interface JMXEnabledThreadPoolExecutorMBean

Returns:

aTasks

See Also:

JMXEnabledThreadPoolExecutorMBean.getActiveTasks()

getQueuedTasks

public int getQueuedTasks()

Description copied from interface: JMXEnabledThreadPoolExecutorMBean

Return the queued tasks

Specified by:

getQueuedTasks in interface JMXEnabledThreadPoolExecutorMBean

Returns:

qTasks

See Also:

JMXEnabledThreadPoolExecutorMBean.getQueuedTasks()

getMaximalThreads

public int getMaximalThreads()

Description copied from interface: JMXEnabledThreadPoolExecutorMBean

Return the maximal allowed count of threads

Specified by:

getMaximalThreads in interface JMXEnabledThreadPoolExecutorMBean

Returns:

maxThreads

See Also:

JMXEnabledThreadPoolExecutorMBean.getMaximalThreads()

newCachedThreadPool

public static JMXEnabledThreadPoolExecutor newCachedThreadPool(String jmxPath,
                                               String name)

Create a cached instance of this class. If jmxPath is null it will not register itself to the MBeanServer

Parameters:

jmxPath -

name -

Returns:

pool

newCachedThreadPool

public static JMXEnabledThreadPoolExecutor newCachedThreadPool(String jmxPath,
                                               NamedThreadFactory factory)

Create a cached instance of this class. If jmxPath is null it will not register itself to the MBeanServer

Parameters:

jmxPath -

factory -

Returns:

pool

newFixedThreadPool

public static JMXEnabledThreadPoolExecutor newFixedThreadPool(String jmxPath,
                                              int nThreads,
                                              NamedThreadFactory threadFactory)

newFixedThreadPool

public static JMXEnabledThreadPoolExecutor newFixedThreadPool(String jmxPath,
                                              String name,
                                              int nThreads)