Package org.cometd.benchmark

Class MonitoringQueuedThreadPool

  • All Implemented Interfaces:
    java.util.concurrent.Executor, java.util.concurrent.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

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void execute​(java.lang.Runnable job)  
      long getAverageQueueLatency()  
      long getAverageTaskLatency()  
      int getMaxActiveThreads()  
      long getMaxQueueLatency()  
      int getMaxQueueSize()  
      long getMaxTaskLatency()  
      long getTasks()  
      void reset()  
      boolean tryExecute​(java.lang.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 Detail

      • MonitoringQueuedThreadPool

        public MonitoringQueuedThreadPool​(int maxThreads)

    • Method Detail

      • execute

        public void execute​(java.lang.Runnable job)
        Specified by:
        execute in interface java.util.concurrent.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​(java.lang.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()