org.apache.james.util.concurrent

Class JMXEnabledScheduledThreadPoolExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

java.util.concurrent.ScheduledThreadPoolExecutor

org.apache.james.util.concurrent.JMXEnabledScheduledThreadPoolExecutor

All Implemented Interfaces:

Executor, ExecutorService, ScheduledExecutorService, JMXEnabledScheduledThreadPoolExecutorMBean, JMXEnabledThreadPoolExecutorMBean

public class JMXEnabledScheduledThreadPoolExecutor
extends ScheduledThreadPoolExecutor
implements JMXEnabledScheduledThreadPoolExecutorMBean

ScheduledThreadPoolExecutor 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
JMXEnabledScheduledThreadPoolExecutor(int corePoolSize, NamedThreadFactory threadFactory, String jmxPath)
JMXEnabledScheduledThreadPoolExecutor(int corePoolSize, 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 java.util.concurrent.ScheduledThreadPoolExecutor

decorateTask, decorateTask, execute, getContinueExistingPeriodicTasksAfterShutdownPolicy, getExecuteExistingDelayedTasksAfterShutdownPolicy, getQueue, getRemoveOnCancelPolicy, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, setContinueExistingPeriodicTasksAfterShutdownPolicy, setExecuteExistingDelayedTasksAfterShutdownPolicy, setRemoveOnCancelPolicy, submit, submit, submit

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, 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

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.concurrent.ExecutorService

awaitTermination, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated

Constructor Detail

JMXEnabledScheduledThreadPoolExecutor

public JMXEnabledScheduledThreadPoolExecutor(int corePoolSize,
                                     NamedThreadFactory threadFactory,
                                     String jmxPath)

JMXEnabledScheduledThreadPoolExecutor

public JMXEnabledScheduledThreadPoolExecutor(int corePoolSize,
                                     String jmxPath,
                                     String name)

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 ScheduledThreadPoolExecutor

shutdownNow

public List<Runnable> shutdownNow()

Specified by:

shutdownNow in interface ExecutorService

Overrides:

shutdownNow in class ScheduledThreadPoolExecutor

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