org.cometd.benchmark

Class MonitoringQueuedThreadPool

java.lang.Object

org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.util.component.ContainerLifeCycle

org.eclipse.jetty.util.thread.QueuedThreadPool

org.cometd.benchmark.MonitoringQueuedThreadPool

All Implemented Interfaces:

Executor, ThreadFactory, org.eclipse.jetty.util.component.Container, org.eclipse.jetty.util.component.Destroyable, org.eclipse.jetty.util.component.Dumpable, org.eclipse.jetty.util.component.Dumpable.DumpableContainer, org.eclipse.jetty.util.component.LifeCycle, org.eclipse.jetty.util.thread.ThreadPool, org.eclipse.jetty.util.thread.ThreadPool.SizedThreadPool, org.eclipse.jetty.util.thread.TryExecutor

public class MonitoringQueuedThreadPool
extends org.eclipse.jetty.util.thread.QueuedThreadPool

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MonitoringQueuedThreadPool.MonitoringBlockingArrayQueue

Nested classes/interfaces inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.util.component.AbstractLifeCycle.AbstractLifeCycleListener

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.thread.ThreadPool

org.eclipse.jetty.util.thread.ThreadPool.SizedThreadPool

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Dumpable

org.eclipse.jetty.util.component.Dumpable.DumpableContainer

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.thread.TryExecutor

org.eclipse.jetty.util.thread.TryExecutor.NoTryExecutor

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Container

org.eclipse.jetty.util.component.Container.InheritedListener, org.eclipse.jetty.util.component.Container.Listener

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.LifeCycle

org.eclipse.jetty.util.component.LifeCycle.Listener

Field Summary

Fields inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

FAILED, RUNNING, STARTED, STARTING, STOPPED, STOPPING

Fields inherited from interface org.eclipse.jetty.util.component.Dumpable

KEY

Fields inherited from interface org.eclipse.jetty.util.thread.TryExecutor

NO_TRY

Constructor Summary

Constructors

Constructor and Description
MonitoringQueuedThreadPool(int maxThreads)

Method Summary

Modifier and Type	Method and Description
void	execute(Runnable job)
long	getAverageQueueLatency()
long	getAverageTaskLatency()
int	getMaxActiveThreads()
long	getMaxQueueLatency()
int	getMaxQueueSize()
long	getMaxTaskLatency()
long	getTasks()
void	reset()
boolean	tryExecute(Runnable job)

Methods inherited from class org.eclipse.jetty.util.thread.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

Methods inherited from class org.eclipse.jetty.util.component.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 org.eclipse.jetty.util.component.AbstractLifeCycle

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.jetty.util.component.Dumpable

dump, dump, dumpContainer, dumpIterable, dumpMapEntries, dumpObject, dumpObjects, dumpSelf, named

Methods inherited from interface org.eclipse.jetty.util.thread.TryExecutor

asTryExecutor

Methods inherited from interface org.eclipse.jetty.util.component.Dumpable.DumpableContainer

isDumpable

Methods inherited from interface org.eclipse.jetty.util.component.LifeCycle

start, stop

Constructor Detail

MonitoringQueuedThreadPool

public MonitoringQueuedThreadPool(int maxThreads)

Method Detail

execute

public void execute(Runnable job)

Specified by:

execute in interface Executor

Specified by:

execute in interface org.eclipse.jetty.util.thread.TryExecutor

Overrides:

execute in class org.eclipse.jetty.util.thread.QueuedThreadPool

tryExecute

public boolean tryExecute(Runnable job)

Specified by:

tryExecute in interface org.eclipse.jetty.util.thread.TryExecutor

Overrides:

tryExecute in class org.eclipse.jetty.util.thread.QueuedThreadPool

reset

public void reset()

getTasks

public long getTasks()

getMaxActiveThreads

public int getMaxActiveThreads()

getMaxQueueSize

public int getMaxQueueSize()

getAverageQueueLatency

public long getAverageQueueLatency()

getMaxQueueLatency

public long getMaxQueueLatency()

getMaxTaskLatency

public long getMaxTaskLatency()

getAverageTaskLatency

public long getAverageTaskLatency()