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