org.eclipse.jetty/jetty-util/10.0.0-alpha0 : org/eclipse/jetty/util/thread/MonitoredQueuedThreadPool.class

MonitoredQueuedThreadPool
http://www.eclipse.org/jetty: Utility classes for Jetty (Webtide)
Greg Wilkins (Webtide, LLC)
Jan Bartel (Webtide, LLC)
Jesse McConnell (Webtide, LLC)
Joakim Erdfelt (Webtide, LLC)
Simone Bordet (Webtide, LLC)
David Jencks (IBM)
Olivier Lamy (Webtide, LLC)
public class org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool extends org.eclipse.jetty.util.thread.QueuedThreadPool
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool
  super_class: org.eclipse.jetty.util.thread.QueuedThreadPool
{
  private final org.eclipse.jetty.util.statistic.CounterStatistic queueStats;
    descriptor: Lorg/eclipse/jetty/util/statistic/CounterStatistic;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final org.eclipse.jetty.util.statistic.SampleStatistic queueLatencyStats;
    descriptor: Lorg/eclipse/jetty/util/statistic/SampleStatistic;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final org.eclipse.jetty.util.statistic.SampleStatistic taskLatencyStats;
    descriptor: Lorg/eclipse/jetty/util/statistic/SampleStatistic;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final org.eclipse.jetty.util.statistic.CounterStatistic threadStats;
    descriptor: Lorg/eclipse/jetty/util/statistic/CounterStatistic;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  public void <init>();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool this
         0: .line 41
            aload 0 /* this */
            sipush 256
            invokespecial org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool.<init>:(I)V
         1: .line 42
            return
        end local 0 // org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/eclipse/jetty/util/thread/MonitoredQueuedThreadPool;

  public void <init>(int);
    descriptor: (I)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=8, locals=2, args_size=2
        start local 0 // org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool this
        start local 1 // int maxThreads
         0: .line 46
            aload 0 /* this */
            iload 1 /* maxThreads */
            iload 1 /* maxThreads */
            ldc 86400000
            new org.eclipse.jetty.util.BlockingArrayQueue
            dup
            iload 1 /* maxThreads */
            sipush 256
            invokespecial org.eclipse.jetty.util.BlockingArrayQueue.<init>:(II)V
            invokespecial org.eclipse.jetty.util.thread.QueuedThreadPool.<init>:(IIILjava/util/concurrent/BlockingQueue;)V
         1: .line 34
            aload 0 /* this */
            new org.eclipse.jetty.util.statistic.CounterStatistic
            dup
            invokespecial org.eclipse.jetty.util.statistic.CounterStatistic.<init>:()V
            putfield org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool.queueStats:Lorg/eclipse/jetty/util/statistic/CounterStatistic;
         2: .line 35
            aload 0 /* this */
            new org.eclipse.jetty.util.statistic.SampleStatistic
            dup
            invokespecial org.eclipse.jetty.util.statistic.SampleStatistic.<init>:()V
            putfield org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool.queueLatencyStats:Lorg/eclipse/jetty/util/statistic/SampleStatistic;
         3: .line 36
            aload 0 /* this */
            new org.eclipse.jetty.util.statistic.SampleStatistic
            dup
            invokespecial org.eclipse.jetty.util.statistic.SampleStatistic.<init>:()V
            putfield org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool.taskLatencyStats:Lorg/eclipse/jetty/util/statistic/SampleStatistic;
         4: .line 37
            aload 0 /* this */
            new org.eclipse.jetty.util.statistic.CounterStatistic
            dup
            invokespecial org.eclipse.jetty.util.statistic.CounterStatistic.<init>:()V
            putfield org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool.threadStats:Lorg/eclipse/jetty/util/statistic/CounterStatistic;
         5: .line 47
            aload 0 /* this */
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool.queueStats:Lorg/eclipse/jetty/util/statistic/CounterStatistic;
            invokevirtual org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool.addBean:(Ljava/lang/Object;)Z
            pop
         6: .line 48
            aload 0 /* this */
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool.queueLatencyStats:Lorg/eclipse/jetty/util/statistic/SampleStatistic;
            invokevirtual org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool.addBean:(Ljava/lang/Object;)Z
            pop
         7: .line 49
            aload 0 /* this */
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool.taskLatencyStats:Lorg/eclipse/jetty/util/statistic/SampleStatistic;
            invokevirtual org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool.addBean:(Ljava/lang/Object;)Z
            pop
         8: .line 50
            aload 0 /* this */
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool.threadStats:Lorg/eclipse/jetty/util/statistic/CounterStatistic;
            invokevirtual org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool.addBean:(Ljava/lang/Object;)Z
            pop
         9: .line 51
            return
        end local 1 // int maxThreads
        end local 0 // org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   10     0        this  Lorg/eclipse/jetty/util/thread/MonitoredQueuedThreadPool;
            0   10     1  maxThreads  I
    MethodParameters:
            Name  Flags
      maxThreads  

  public void execute(java.lang.Runnable);
    descriptor: (Ljava/lang/Runnable;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=4, args_size=2
        start local 0 // org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool this
        start local 1 // java.lang.Runnable job
         0: .line 56
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool.queueStats:Lorg/eclipse/jetty/util/statistic/CounterStatistic;
            invokevirtual org.eclipse.jetty.util.statistic.CounterStatistic.increment:()J
            pop2
         1: .line 57
            invokestatic java.lang.System.nanoTime:()J
            lstore 2 /* begin */
        start local 2 // long begin
         2: .line 58
            aload 0 /* this */
            new org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool$1
            dup
            aload 0 /* this */
            lload 2 /* begin */
            aload 1 /* job */
            invokespecial org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool$1.<init>:(Lorg/eclipse/jetty/util/thread/MonitoredQueuedThreadPool;JLjava/lang/Runnable;)V
            invokespecial org.eclipse.jetty.util.thread.QueuedThreadPool.execute:(Ljava/lang/Runnable;)V
         3: .line 86
            return
        end local 2 // long begin
        end local 1 // java.lang.Runnable job
        end local 0 // org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    4     0   this  Lorg/eclipse/jetty/util/thread/MonitoredQueuedThreadPool;
            0    4     1    job  Ljava/lang/Runnable;
            2    4     2  begin  J
    MethodParameters:
      Name  Flags
      job   final

  public void reset();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool this
         0: .line 94
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool.queueStats:Lorg/eclipse/jetty/util/statistic/CounterStatistic;
            invokevirtual org.eclipse.jetty.util.statistic.CounterStatistic.reset:()V
         1: .line 95
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool.queueLatencyStats:Lorg/eclipse/jetty/util/statistic/SampleStatistic;
            invokevirtual org.eclipse.jetty.util.statistic.SampleStatistic.reset:()V
         2: .line 96
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool.taskLatencyStats:Lorg/eclipse/jetty/util/statistic/SampleStatistic;
            invokevirtual org.eclipse.jetty.util.statistic.SampleStatistic.reset:()V
         3: .line 97
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool.threadStats:Lorg/eclipse/jetty/util/statistic/CounterStatistic;
            lconst_0
            invokevirtual org.eclipse.jetty.util.statistic.CounterStatistic.reset:(J)V
         4: .line 98
            return
        end local 0 // org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lorg/eclipse/jetty/util/thread/MonitoredQueuedThreadPool;
    RuntimeVisibleAnnotations: 
      org.eclipse.jetty.util.annotation.ManagedOperation(value = "resets the statistics", impact = "ACTION")

  public long getTasks();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool this
         0: .line 106
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool.taskLatencyStats:Lorg/eclipse/jetty/util/statistic/SampleStatistic;
            invokevirtual org.eclipse.jetty.util.statistic.SampleStatistic.getTotal:()J
            lreturn
        end local 0 // org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/util/thread/MonitoredQueuedThreadPool;
    RuntimeVisibleAnnotations: 
      org.eclipse.jetty.util.annotation.ManagedAttribute(value = "the number of tasks executed")

  public int getMaxBusyThreads();
    descriptor: ()I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool this
         0: .line 115
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool.threadStats:Lorg/eclipse/jetty/util/statistic/CounterStatistic;
            invokevirtual org.eclipse.jetty.util.statistic.CounterStatistic.getMax:()J
            l2i
            ireturn
        end local 0 // org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/util/thread/MonitoredQueuedThreadPool;
    RuntimeVisibleAnnotations: 
      org.eclipse.jetty.util.annotation.ManagedAttribute(value = "the maximum number of busy threads")

  public int getMaxQueueSize();
    descriptor: ()I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool this
         0: .line 124
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool.queueStats:Lorg/eclipse/jetty/util/statistic/CounterStatistic;
            invokevirtual org.eclipse.jetty.util.statistic.CounterStatistic.getMax:()J
            l2i
            ireturn
        end local 0 // org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/util/thread/MonitoredQueuedThreadPool;
    RuntimeVisibleAnnotations: 
      org.eclipse.jetty.util.annotation.ManagedAttribute(value = "the maximum task queue size")

  public long getAverageQueueLatency();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool this
         0: .line 133
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool.queueLatencyStats:Lorg/eclipse/jetty/util/statistic/SampleStatistic;
            invokevirtual org.eclipse.jetty.util.statistic.SampleStatistic.getMean:()D
            d2l
            lreturn
        end local 0 // org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/util/thread/MonitoredQueuedThreadPool;
    RuntimeVisibleAnnotations: 
      org.eclipse.jetty.util.annotation.ManagedAttribute(value = "the average time a task remains in the queue, in nanoseconds")

  public long getMaxQueueLatency();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool this
         0: .line 142
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool.queueLatencyStats:Lorg/eclipse/jetty/util/statistic/SampleStatistic;
            invokevirtual org.eclipse.jetty.util.statistic.SampleStatistic.getMax:()J
            lreturn
        end local 0 // org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/util/thread/MonitoredQueuedThreadPool;
    RuntimeVisibleAnnotations: 
      org.eclipse.jetty.util.annotation.ManagedAttribute(value = "the maximum time a task remains in the queue, in nanoseconds")

  public long getAverageTaskLatency();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool this
         0: .line 151
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool.taskLatencyStats:Lorg/eclipse/jetty/util/statistic/SampleStatistic;
            invokevirtual org.eclipse.jetty.util.statistic.SampleStatistic.getMean:()D
            d2l
            lreturn
        end local 0 // org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/util/thread/MonitoredQueuedThreadPool;
    RuntimeVisibleAnnotations: 
      org.eclipse.jetty.util.annotation.ManagedAttribute(value = "the average task execution time, in nanoseconds")

  public long getMaxTaskLatency();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool this
         0: .line 160
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool.taskLatencyStats:Lorg/eclipse/jetty/util/statistic/SampleStatistic;
            invokevirtual org.eclipse.jetty.util.statistic.SampleStatistic.getMax:()J
            lreturn
        end local 0 // org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/util/thread/MonitoredQueuedThreadPool;
    RuntimeVisibleAnnotations: 
      org.eclipse.jetty.util.annotation.ManagedAttribute(value = "the maximum task execution time, in nanoseconds")
}
SourceFile: "MonitoredQueuedThreadPool.java"
NestMembers:
  org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool$1
InnerClasses:
  org.eclipse.jetty.util.thread.MonitoredQueuedThreadPool$1
    RuntimeVisibleAnnotations: 
      org.eclipse.jetty.util.annotation.ManagedObject()
/

org.eclipse.jetty/ jetty-util/ 10.0.0-alpha0/ org/eclipse/jetty/util/thread/MonitoredQueuedThreadPool.class
