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:
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

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​(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, getBusyThreads, getIdleThreads, getIdleTimeout, getLowThreadsThreshold, getMaxThreads, getMinThreads, getName, getQueue, getQueueSize, getReservedThreads, getStopTimeout, getThreadPoolBudget, getThreads, getThreadsPriority, interruptThread, isDaemon, isDetailedDump, isLowOnThreads, join, newThread, removeThread, runJob, setDaemon, setDetailedDump, setIdleTimeout, setLowThreadsThreshold, setMaxThreads, setMinThreads, setName, setReservedThreads, setStopTimeout, setThreadPoolBudget, setThreadsPriority, 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

    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
  • Constructor Details

    • MonitoringQueuedThreadPool

      public MonitoringQueuedThreadPool​(int maxThreads)
  • Method Details

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