Package 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, org.eclipse.jetty.util.VirtualThreads.Configurable

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MonitoringQueuedThreadPool.MonitoringBlockingArrayQueue

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

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

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.Dumpable

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

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

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

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.thread.TryExecutor

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

Field Summary

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

FAILED, 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	Description
MonitoringQueuedThreadPool(int maxThreads)

Method Summary

Modifier and Type	Method	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, evict, getAvailableReservedThreads, getBusyThreads, getIdleThreads, getIdleTimeout, getLeasedThreads, getLowThreadsThreshold, getMaxAvailableThreads, getMaxEvictCount, getMaxLeasedThreads, getMaxReservedThreads, getMaxThreads, getMinThreads, getName, getQueue, getQueueSize, getReadyThreads, getReservedThreads, getStopTimeout, getThreadPoolBudget, getThreads, getThreadsPriority, getUtilizationRate, getUtilizedThreads, getVirtualThreadsExecutor, interruptThread, isDaemon, isDetailedDump, isLowOnThreads, join, newThread, removeThread, runJob, setDaemon, setDetailedDump, setIdleTimeout, setLowThreadsThreshold, setMaxEvictCount, setMaxThreads, setMinThreads, setName, setReservedThreads, setStopTimeout, setThreadPoolBudget, setThreadsPriority, setVirtualThreadsExecutor, startThread, toString

Methods inherited from class org.eclipse.jetty.util.component.ContainerLifeCycle

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

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

getEventListeners, getState, getState, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, setEventListeners, 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.Container

getCachedBeans, getEventListeners

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

dump, dumpSelf

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

isDumpable

Methods inherited from interface org.eclipse.jetty.util.VirtualThreads.Configurable

isUseVirtualThreads, setUseVirtualThreads

Constructor Details

MonitoringQueuedThreadPool

public MonitoringQueuedThreadPool(int maxThreads)

Method Details

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