Class MonitoredQueuedThreadPool

java.lang.Object

org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.util.component.ContainerLifeCycle

org.eclipse.jetty.util.thread.QueuedThreadPool

org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool

All Implemented Interfaces:

Executor, ThreadFactory, Container, Destroyable, Dumpable, Dumpable.DumpableContainer, LifeCycle, ThreadPool, ThreadPool.SizedThreadPool, TryExecutor

@ManagedObject
public class MonitoredQueuedThreadPool
extends QueuedThreadPool

A QueuedThreadPool subclass that monitors its own activity by recording queue and task statistics.

Nested Class Summary

Nested classes/interfaces inherited from class AbstractLifeCycle

AbstractLifeCycle.AbstractLifeCycleListener

Nested classes/interfaces inherited from interface Container

Container.InheritedListener, Container.Listener

Nested classes/interfaces inherited from interface Dumpable

Dumpable.DumpableContainer

Nested classes/interfaces inherited from interface LifeCycle

LifeCycle.Listener

Nested classes/interfaces inherited from interface ThreadPool

ThreadPool.SizedThreadPool

Nested classes/interfaces inherited from interface TryExecutor

TryExecutor.NoTryExecutor

Field Summary

Fields

Modifier and Type	Field	Description
private final SampleStatistic	queueLatencyStats
private final CounterStatistic	queueStats
private final SampleStatistic	taskLatencyStats
private final CounterStatistic	threadStats

Fields inherited from class AbstractLifeCycle

FAILED, RUNNING, STARTED, STARTING, STOPPED, STOPPING

Fields inherited from interface Dumpable

KEY

Fields inherited from interface TryExecutor

NO_TRY

Constructor Summary

Constructors

Constructor	Description
MonitoredQueuedThreadPool()
MonitoredQueuedThreadPool(int maxThreads)
MonitoredQueuedThreadPool(int maxThreads, int minThreads, int idleTimeOut, BlockingQueue<Runnable> queue)

Method Summary

Modifier and Type	Method	Description
void	execute(Runnable job)
long	getAverageQueueLatency()
long	getAverageTaskLatency()
int	getMaxBusyThreads()
long	getMaxQueueLatency()
int	getMaxQueueSize()
long	getMaxTaskLatency()
long	getTasks()
void	reset()	Resets the statistics.

Methods inherited from class QueuedThreadPool

doStart, doStop, dump, dumpThread, getAvailableReservedThreads, getBusyThreads, getIdleThreads, getIdleTimeout, getLeasedThreads, getLowThreadsThreshold, getMaxAvailableThreads, getMaxLeasedThreads, getMaxReservedThreads, getMaxThreads, getMinThreads, getName, getQueue, getQueueSize, getReadyThreads, getReservedThreads, getThreadPoolBudget, getThreads, getThreadsPriority, getUtilizationRate, getUtilizedThreads, interruptThread, isDaemon, isDetailedDump, isLowOnThreads, join, newThread, removeThread, runJob, setDaemon, setDetailedDump, setIdleTimeout, setLowThreadsThreshold, setMaxThreads, setMinThreads, setName, setQueue, setReservedThreads, setThreadPoolBudget, setThreadsPriority, startThread, toString, tryExecute

Methods inherited from class ContainerLifeCycle

addBean, addBean, addEventListener, addManaged, contains, destroy, dump, dump, dump, dump, dumpBeans, dumpObject, dumpObjects, dumpStdErr, dumpThis, getBean, getBeans, getBeans, getContainedBeans, getContainedBeans, isAuto, isManaged, isUnmanaged, manage, removeBean, removeBeans, removeEventListener, setBeans, setStopTimeout, start, stop, unmanage, updateBean, updateBean, updateBeans

Methods inherited from class AbstractLifeCycle

addLifeCycleListener, getState, getState, getStopTimeout, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stop

Methods inherited from class Object

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

Methods inherited from interface Dumpable

dump, dumpSelf

Methods inherited from interface Dumpable.DumpableContainer

isDumpable

Field Details

queueStats

private final CounterStatistic queueStats

queueLatencyStats

private final SampleStatistic queueLatencyStats

taskLatencyStats

private final SampleStatistic taskLatencyStats

threadStats

private final CounterStatistic threadStats

Constructor Details

MonitoredQueuedThreadPool

public MonitoredQueuedThreadPool()

MonitoredQueuedThreadPool

public MonitoredQueuedThreadPool(int maxThreads)

MonitoredQueuedThreadPool

public MonitoredQueuedThreadPool(int maxThreads,
 int minThreads,
 int idleTimeOut,
 BlockingQueue<Runnable> queue)

Method Details

execute

public void execute(Runnable job)

Specified by:

execute in interface Executor

Specified by:

execute in interface TryExecutor

Overrides:

execute in class QueuedThreadPool

reset

@ManagedOperation(value="resets the statistics",
                  impact="ACTION")
public void reset()

Resets the statistics.

getTasks

@ManagedAttribute("the number of tasks executed")
public long getTasks()

Returns:

the number of tasks executed

getMaxBusyThreads

@ManagedAttribute("the maximum number of busy threads")
public int getMaxBusyThreads()

Returns:

the maximum number of busy threads

getMaxQueueSize

@ManagedAttribute("the maximum task queue size")
public int getMaxQueueSize()

Returns:

the maximum task queue size

getAverageQueueLatency

@ManagedAttribute("the average time a task remains in the queue, in nanoseconds")
public long getAverageQueueLatency()

Returns:

the average time a task remains in the queue, in nanoseconds

getMaxQueueLatency

@ManagedAttribute("the maximum time a task remains in the queue, in nanoseconds")
public long getMaxQueueLatency()

Returns:

the maximum time a task remains in the queue, in nanoseconds

getAverageTaskLatency

@ManagedAttribute("the average task execution time, in nanoseconds")
public long getAverageTaskLatency()

Returns:

the average task execution time, in nanoseconds

getMaxTaskLatency

@ManagedAttribute("the maximum task execution time, in nanoseconds")
public long getMaxTaskLatency()

Returns:

the maximum task execution time, in nanoseconds