org.apache.james.protocols.lib.netty

Class JMXEnabledOrderedMemoryAwareThreadPoolExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

org.jboss.netty.handler.execution.MemoryAwareThreadPoolExecutor

org.jboss.netty.handler.execution.OrderedMemoryAwareThreadPoolExecutor

org.apache.james.protocols.lib.netty.JMXEnabledOrderedMemoryAwareThreadPoolExecutor

All Implemented Interfaces:

Executor, ExecutorService, JMXEnabledOrderedMemoryAwareThreadPoolExecutorMBean, JMXEnabledThreadPoolExecutorMBean

public class JMXEnabledOrderedMemoryAwareThreadPoolExecutor
extends org.jboss.netty.handler.execution.OrderedMemoryAwareThreadPoolExecutor
implements JMXEnabledOrderedMemoryAwareThreadPoolExecutorMBean

OrderedMemoryAwareThreadPoolExecutor subclass 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
JMXEnabledOrderedMemoryAwareThreadPoolExecutor(int corePoolSize, long maxChannelMemorySize, long maxTotalMemorySize, String jmxPath, String name)

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
void	shutdown()
List<Runnable>	shutdownNow()

Methods inherited from class org.jboss.netty.handler.execution.OrderedMemoryAwareThreadPoolExecutor

doExecute, getChildExecutorKey, getChildExecutorKeySet, newChildExecutorMap, removeChildExecutor, shouldCount

Methods inherited from class org.jboss.netty.handler.execution.MemoryAwareThreadPoolExecutor

decreaseCounter, doUnorderedExecute, execute, getMaxChannelMemorySize, getMaxTotalMemorySize, getObjectSizeEstimator, increaseCounter, remove, setMaxChannelMemorySize, setMaxTotalMemorySize, setObjectSizeEstimator, terminated

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getQueue, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, 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

JMXEnabledOrderedMemoryAwareThreadPoolExecutor

public JMXEnabledOrderedMemoryAwareThreadPoolExecutor(int corePoolSize,
                                              long maxChannelMemorySize,
                                              long maxTotalMemorySize,
                                              String jmxPath,
                                              String name)

Method Detail

beforeExecute

protected void beforeExecute(Thread t,
                 Runnable r)

Overrides:

beforeExecute in class org.jboss.netty.handler.execution.MemoryAwareThreadPoolExecutor

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()