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

ReservedThreadExecutor
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.ReservedThreadExecutor extends org.eclipse.jetty.util.component.AbstractLifeCycle implements org.eclipse.jetty.util.thread.TryExecutor
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.eclipse.jetty.util.thread.ReservedThreadExecutor
  super_class: org.eclipse.jetty.util.component.AbstractLifeCycle
{
  private static final org.eclipse.jetty.util.log.Logger LOG;
    descriptor: Lorg/eclipse/jetty/util/log/Logger;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private static final java.lang.Runnable STOP;
    descriptor: Ljava/lang/Runnable;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private final java.util.concurrent.Executor _executor;
    descriptor: Ljava/util/concurrent/Executor;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final int _capacity;
    descriptor: I
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.util.concurrent.ConcurrentLinkedDeque<org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread> _stack;
    descriptor: Ljava/util/concurrent/ConcurrentLinkedDeque;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/concurrent/ConcurrentLinkedDeque<Lorg/eclipse/jetty/util/thread/ReservedThreadExecutor$ReservedThread;>;

  private final java.util.concurrent.atomic.AtomicInteger _size;
    descriptor: Ljava/util/concurrent/atomic/AtomicInteger;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.util.concurrent.atomic.AtomicInteger _pending;
    descriptor: Ljava/util/concurrent/atomic/AtomicInteger;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private org.eclipse.jetty.util.thread.ThreadPoolBudget$Lease _lease;
    descriptor: Lorg/eclipse/jetty/util/thread/ThreadPoolBudget$Lease;
    flags: (0x0002) ACC_PRIVATE

  private long _idleTime;
    descriptor: J
    flags: (0x0002) ACC_PRIVATE

  private java.util.concurrent.TimeUnit _idleTimeUnit;
    descriptor: Ljava/util/concurrent/TimeUnit;
    flags: (0x0002) ACC_PRIVATE

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=2, locals=0, args_size=0
         0: .line 48
            ldc Lorg/eclipse/jetty/util/thread/ReservedThreadExecutor;
            invokestatic org.eclipse.jetty.util.log.Log.getLogger:(Ljava/lang/Class;)Lorg/eclipse/jetty/util/log/Logger;
            putstatic org.eclipse.jetty.util.thread.ReservedThreadExecutor.LOG:Lorg/eclipse/jetty/util/log/Logger;
         1: .line 49
            new org.eclipse.jetty.util.thread.ReservedThreadExecutor$1
            dup
            invokespecial org.eclipse.jetty.util.thread.ReservedThreadExecutor$1.<init>:()V
            putstatic org.eclipse.jetty.util.thread.ReservedThreadExecutor.STOP:Ljava/lang/Runnable;
         2: .line 61
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>(java.util.concurrent.Executor, int);
    descriptor: (Ljava/util/concurrent/Executor;I)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=3, args_size=3
        start local 0 // org.eclipse.jetty.util.thread.ReservedThreadExecutor this
        start local 1 // java.util.concurrent.Executor executor
        start local 2 // int capacity
         0: .line 79
            aload 0 /* this */
            invokespecial org.eclipse.jetty.util.component.AbstractLifeCycle.<init>:()V
         1: .line 66
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicInteger
            dup
            invokespecial java.util.concurrent.atomic.AtomicInteger.<init>:()V
            putfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._size:Ljava/util/concurrent/atomic/AtomicInteger;
         2: .line 67
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicInteger
            dup
            invokespecial java.util.concurrent.atomic.AtomicInteger.<init>:()V
            putfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._pending:Ljava/util/concurrent/atomic/AtomicInteger;
         3: .line 70
            aload 0 /* this */
            lconst_1
            putfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._idleTime:J
         4: .line 71
            aload 0 /* this */
            getstatic java.util.concurrent.TimeUnit.MINUTES:Ljava/util/concurrent/TimeUnit;
            putfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._idleTimeUnit:Ljava/util/concurrent/TimeUnit;
         5: .line 81
            aload 0 /* this */
            aload 1 /* executor */
            putfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._executor:Ljava/util/concurrent/Executor;
         6: .line 82
            aload 0 /* this */
            aload 1 /* executor */
            iload 2 /* capacity */
            invokestatic org.eclipse.jetty.util.thread.ReservedThreadExecutor.reservedThreads:(Ljava/util/concurrent/Executor;I)I
            putfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._capacity:I
         7: .line 83
            aload 0 /* this */
            new java.util.concurrent.ConcurrentLinkedDeque
            dup
            invokespecial java.util.concurrent.ConcurrentLinkedDeque.<init>:()V
            putfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._stack:Ljava/util/concurrent/ConcurrentLinkedDeque;
         8: .line 85
            getstatic org.eclipse.jetty.util.thread.ReservedThreadExecutor.LOG:Lorg/eclipse/jetty/util/log/Logger;
            ldc "{}"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            aastore
            invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
         9: .line 86
            return
        end local 2 // int capacity
        end local 1 // java.util.concurrent.Executor executor
        end local 0 // org.eclipse.jetty.util.thread.ReservedThreadExecutor this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   10     0      this  Lorg/eclipse/jetty/util/thread/ReservedThreadExecutor;
            0   10     1  executor  Ljava/util/concurrent/Executor;
            0   10     2  capacity  I
    MethodParameters:
          Name  Flags
      executor  
      capacity  

  private static int reservedThreads(java.util.concurrent.Executor, int);
    descriptor: (Ljava/util/concurrent/Executor;I)I
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=4, locals=4, args_size=2
        start local 0 // java.util.concurrent.Executor executor
        start local 1 // int capacity
         0: .line 98
            iload 1 /* capacity */
            iflt 2
         1: .line 99
            iload 1 /* capacity */
            ireturn
         2: .line 100
      StackMap locals:
      StackMap stack:
            invokestatic org.eclipse.jetty.util.ProcessorUtils.availableProcessors:()I
            istore 2 /* cpus */
        start local 2 // int cpus
         3: .line 101
            aload 0 /* executor */
            instanceof org.eclipse.jetty.util.thread.ThreadPool$SizedThreadPool
            ifeq 6
         4: .line 103
            aload 0 /* executor */
            checkcast org.eclipse.jetty.util.thread.ThreadPool$SizedThreadPool
            invokeinterface org.eclipse.jetty.util.thread.ThreadPool$SizedThreadPool.getMaxThreads:()I
            istore 3 /* threads */
        start local 3 // int threads
         5: .line 104
            iconst_1
            iload 2 /* cpus */
            iload 3 /* threads */
            bipush 10
            idiv
            invokestatic java.lang.Math.min:(II)I
            invokestatic java.lang.Math.max:(II)I
            ireturn
        end local 3 // int threads
         6: .line 106
      StackMap locals: int
      StackMap stack:
            iload 2 /* cpus */
            ireturn
        end local 2 // int cpus
        end local 1 // int capacity
        end local 0 // java.util.concurrent.Executor executor
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    7     0  executor  Ljava/util/concurrent/Executor;
            0    7     1  capacity  I
            3    7     2      cpus  I
            5    6     3   threads  I
    MethodParameters:
          Name  Flags
      executor  
      capacity  

  public java.util.concurrent.Executor getExecutor();
    descriptor: ()Ljava/util/concurrent/Executor;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.ReservedThreadExecutor this
         0: .line 111
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._executor:Ljava/util/concurrent/Executor;
            areturn
        end local 0 // org.eclipse.jetty.util.thread.ReservedThreadExecutor this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/util/thread/ReservedThreadExecutor;

  public int getCapacity();
    descriptor: ()I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.ReservedThreadExecutor this
         0: .line 117
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._capacity:I
            ireturn
        end local 0 // org.eclipse.jetty.util.thread.ReservedThreadExecutor this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/util/thread/ReservedThreadExecutor;
    RuntimeVisibleAnnotations: 
      org.eclipse.jetty.util.annotation.ManagedAttribute(value = "max number of reserved threads", readonly = true)

  public int getAvailable();
    descriptor: ()I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.ReservedThreadExecutor this
         0: .line 123
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._stack:Ljava/util/concurrent/ConcurrentLinkedDeque;
            invokevirtual java.util.concurrent.ConcurrentLinkedDeque.size:()I
            ireturn
        end local 0 // org.eclipse.jetty.util.thread.ReservedThreadExecutor this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/util/thread/ReservedThreadExecutor;
    RuntimeVisibleAnnotations: 
      org.eclipse.jetty.util.annotation.ManagedAttribute(value = "available reserved threads", readonly = true)

  public int getPending();
    descriptor: ()I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.ReservedThreadExecutor this
         0: .line 129
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._pending:Ljava/util/concurrent/atomic/AtomicInteger;
            invokevirtual java.util.concurrent.atomic.AtomicInteger.get:()I
            ireturn
        end local 0 // org.eclipse.jetty.util.thread.ReservedThreadExecutor this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/util/thread/ReservedThreadExecutor;
    RuntimeVisibleAnnotations: 
      org.eclipse.jetty.util.annotation.ManagedAttribute(value = "pending reserved threads", readonly = true)

  public long getIdleTimeoutMs();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.ReservedThreadExecutor this
         0: .line 135
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._idleTimeUnit:Ljava/util/concurrent/TimeUnit;
            ifnonnull 2
         1: .line 136
            lconst_0
            lreturn
         2: .line 137
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._idleTimeUnit:Ljava/util/concurrent/TimeUnit;
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._idleTime:J
            invokevirtual java.util.concurrent.TimeUnit.toMillis:(J)J
            lreturn
        end local 0 // org.eclipse.jetty.util.thread.ReservedThreadExecutor this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lorg/eclipse/jetty/util/thread/ReservedThreadExecutor;
    RuntimeVisibleAnnotations: 
      org.eclipse.jetty.util.annotation.ManagedAttribute(value = "idletimeout in MS", readonly = true)

  public void setIdleTimeout(long, java.util.concurrent.TimeUnit);
    descriptor: (JLjava/util/concurrent/TimeUnit;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=4, args_size=3
        start local 0 // org.eclipse.jetty.util.thread.ReservedThreadExecutor this
        start local 1 // long idleTime
        start local 3 // java.util.concurrent.TimeUnit idleTimeUnit
         0: .line 148
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.util.thread.ReservedThreadExecutor.isRunning:()Z
            ifeq 2
         1: .line 149
            new java.lang.IllegalStateException
            dup
            invokespecial java.lang.IllegalStateException.<init>:()V
            athrow
         2: .line 150
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            lload 1 /* idleTime */
            putfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._idleTime:J
         3: .line 151
            aload 0 /* this */
            aload 3 /* idleTimeUnit */
            putfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._idleTimeUnit:Ljava/util/concurrent/TimeUnit;
         4: .line 152
            return
        end local 3 // java.util.concurrent.TimeUnit idleTimeUnit
        end local 1 // long idleTime
        end local 0 // org.eclipse.jetty.util.thread.ReservedThreadExecutor this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    5     0          this  Lorg/eclipse/jetty/util/thread/ReservedThreadExecutor;
            0    5     1      idleTime  J
            0    5     3  idleTimeUnit  Ljava/util/concurrent/TimeUnit;
    MethodParameters:
              Name  Flags
      idleTime      
      idleTimeUnit  

  public void doStart();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.ReservedThreadExecutor this
         0: .line 157
            aload 0 /* this */
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.util.thread.ReservedThreadExecutor.getExecutor:()Ljava/util/concurrent/Executor;
            aload 0 /* this */
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._capacity:I
            invokestatic org.eclipse.jetty.util.thread.ThreadPoolBudget.leaseFrom:(Ljava/util/concurrent/Executor;Ljava/lang/Object;I)Lorg/eclipse/jetty/util/thread/ThreadPoolBudget$Lease;
            putfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._lease:Lorg/eclipse/jetty/util/thread/ThreadPoolBudget$Lease;
         1: .line 158
            aload 0 /* this */
            invokespecial org.eclipse.jetty.util.component.AbstractLifeCycle.doStart:()V
         2: .line 159
            return
        end local 0 // org.eclipse.jetty.util.thread.ReservedThreadExecutor this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lorg/eclipse/jetty/util/thread/ReservedThreadExecutor;
    Exceptions:
      throws java.lang.Exception

  public void doStop();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=2, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.ReservedThreadExecutor this
         0: .line 164
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._lease:Lorg/eclipse/jetty/util/thread/ThreadPoolBudget$Lease;
            ifnull 2
         1: .line 165
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._lease:Lorg/eclipse/jetty/util/thread/ThreadPoolBudget$Lease;
            invokeinterface org.eclipse.jetty.util.thread.ThreadPoolBudget$Lease.close:()V
         2: .line 168
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._stack:Ljava/util/concurrent/ConcurrentLinkedDeque;
            invokevirtual java.util.concurrent.ConcurrentLinkedDeque.pollFirst:()Ljava/lang/Object;
            checkcast org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread
            astore 1 /* thread */
        start local 1 // org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread thread
         3: .line 169
            aload 1 /* thread */
            ifnonnull 5
         4: .line 170
            goto 8
         5: .line 171
      StackMap locals: org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._size:Ljava/util/concurrent/atomic/AtomicInteger;
            invokevirtual java.util.concurrent.atomic.AtomicInteger.decrementAndGet:()I
            pop
         6: .line 172
            aload 1 /* thread */
            invokevirtual org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.stop:()V
        end local 1 // org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread thread
         7: .line 166
            goto 2
         8: .line 174
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokespecial org.eclipse.jetty.util.component.AbstractLifeCycle.doStop:()V
         9: .line 175
            return
        end local 0 // org.eclipse.jetty.util.thread.ReservedThreadExecutor this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   10     0    this  Lorg/eclipse/jetty/util/thread/ReservedThreadExecutor;
            3    7     1  thread  Lorg/eclipse/jetty/util/thread/ReservedThreadExecutor$ReservedThread;
    Exceptions:
      throws java.lang.Exception

  public void execute(java.lang.Runnable);
    descriptor: (Ljava/lang/Runnable;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.eclipse.jetty.util.thread.ReservedThreadExecutor this
        start local 1 // java.lang.Runnable task
         0: .line 180
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._executor:Ljava/util/concurrent/Executor;
            aload 1 /* task */
            invokeinterface java.util.concurrent.Executor.execute:(Ljava/lang/Runnable;)V
         1: .line 181
            return
        end local 1 // java.lang.Runnable task
        end local 0 // org.eclipse.jetty.util.thread.ReservedThreadExecutor this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/eclipse/jetty/util/thread/ReservedThreadExecutor;
            0    2     1  task  Ljava/lang/Runnable;
    Exceptions:
      throws java.util.concurrent.RejectedExecutionException
    MethodParameters:
      Name  Flags
      task  

  public boolean tryExecute(java.lang.Runnable);
    descriptor: (Ljava/lang/Runnable;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=4, args_size=2
        start local 0 // org.eclipse.jetty.util.thread.ReservedThreadExecutor this
        start local 1 // java.lang.Runnable task
         0: .line 190
            getstatic org.eclipse.jetty.util.thread.ReservedThreadExecutor.LOG:Lorg/eclipse/jetty/util/log/Logger;
            invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
            ifeq 2
         1: .line 191
            getstatic org.eclipse.jetty.util.thread.ReservedThreadExecutor.LOG:Lorg/eclipse/jetty/util/log/Logger;
            ldc "{} tryExecute {}"
            iconst_2
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            aastore
            dup
            iconst_1
            aload 1 /* task */
            aastore
            invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
         2: .line 193
      StackMap locals:
      StackMap stack:
            aload 1 /* task */
            ifnonnull 4
         3: .line 194
            iconst_0
            ireturn
         4: .line 196
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._stack:Ljava/util/concurrent/ConcurrentLinkedDeque;
            invokevirtual java.util.concurrent.ConcurrentLinkedDeque.pollFirst:()Ljava/lang/Object;
            checkcast org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread
            astore 2 /* thread */
        start local 2 // org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread thread
         5: .line 197
            aload 2 /* thread */
            ifnonnull 8
            aload 1 /* task */
            getstatic org.eclipse.jetty.util.thread.ReservedThreadExecutor.STOP:Ljava/lang/Runnable;
            if_acmpeq 8
         6: .line 199
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.util.thread.ReservedThreadExecutor.startReservedThread:()V
         7: .line 200
            iconst_0
            ireturn
         8: .line 203
      StackMap locals: org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._size:Ljava/util/concurrent/atomic/AtomicInteger;
            invokevirtual java.util.concurrent.atomic.AtomicInteger.decrementAndGet:()I
            istore 3 /* size */
        start local 3 // int size
         9: .line 204
            aload 2 /* thread */
            aload 1 /* task */
            invokevirtual org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.offer:(Ljava/lang/Runnable;)V
        10: .line 206
            iload 3 /* size */
            ifne 12
            aload 1 /* task */
            getstatic org.eclipse.jetty.util.thread.ReservedThreadExecutor.STOP:Ljava/lang/Runnable;
            if_acmpeq 12
        11: .line 207
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.util.thread.ReservedThreadExecutor.startReservedThread:()V
        12: .line 209
      StackMap locals: int
      StackMap stack:
            iconst_1
            ireturn
        end local 3 // int size
        end local 2 // org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread thread
        end local 1 // java.lang.Runnable task
        end local 0 // org.eclipse.jetty.util.thread.ReservedThreadExecutor this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   13     0    this  Lorg/eclipse/jetty/util/thread/ReservedThreadExecutor;
            0   13     1    task  Ljava/lang/Runnable;
            5   13     2  thread  Lorg/eclipse/jetty/util/thread/ReservedThreadExecutor$ReservedThread;
            9   13     3    size  I
    MethodParameters:
      Name  Flags
      task  

  private void startReservedThread();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=7, locals=3, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.ReservedThreadExecutor this
         0: .line 219
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._pending:Ljava/util/concurrent/atomic/AtomicInteger;
            invokevirtual java.util.concurrent.atomic.AtomicInteger.get:()I
            istore 1 /* pending */
        start local 1 // int pending
         1: .line 220
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._size:Ljava/util/concurrent/atomic/AtomicInteger;
            invokevirtual java.util.concurrent.atomic.AtomicInteger.get:()I
            istore 2 /* size */
        start local 2 // int size
         2: .line 221
            iload 1 /* pending */
            iload 2 /* size */
            iadd
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._capacity:I
            if_icmplt 4
         3: .line 222
            return
         4: .line 223
      StackMap locals: int int
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._pending:Ljava/util/concurrent/atomic/AtomicInteger;
            iload 1 /* pending */
            iload 1 /* pending */
            iconst_1
            iadd
            invokevirtual java.util.concurrent.atomic.AtomicInteger.compareAndSet:(II)Z
            ifeq 0
         5: .line 225
            getstatic org.eclipse.jetty.util.thread.ReservedThreadExecutor.LOG:Lorg/eclipse/jetty/util/log/Logger;
            invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
            ifeq 7
         6: .line 226
            getstatic org.eclipse.jetty.util.thread.ReservedThreadExecutor.LOG:Lorg/eclipse/jetty/util/log/Logger;
            ldc "{} startReservedThread p={}"
            iconst_2
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            aastore
            dup
            iconst_1
            iload 1 /* pending */
            iconst_1
            iadd
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
         7: .line 227
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._executor:Ljava/util/concurrent/Executor;
            new org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread
            dup
            aload 0 /* this */
            invokespecial org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.<init>:(Lorg/eclipse/jetty/util/thread/ReservedThreadExecutor;)V
            invokeinterface java.util.concurrent.Executor.execute:(Ljava/lang/Runnable;)V
         8: .line 228
            return
        end local 2 // int size
        end local 1 // int pending
         9: .line 232
      StackMap locals: org.eclipse.jetty.util.thread.ReservedThreadExecutor
      StackMap stack: java.util.concurrent.RejectedExecutionException
            astore 1 /* e */
        start local 1 // java.util.concurrent.RejectedExecutionException e
        10: .line 234
            getstatic org.eclipse.jetty.util.thread.ReservedThreadExecutor.LOG:Lorg/eclipse/jetty/util/log/Logger;
            aload 1 /* e */
            invokeinterface org.eclipse.jetty.util.log.Logger.ignore:(Ljava/lang/Throwable;)V
        end local 1 // java.util.concurrent.RejectedExecutionException e
        11: .line 236
            return
        end local 0 // org.eclipse.jetty.util.thread.ReservedThreadExecutor this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   12     0     this  Lorg/eclipse/jetty/util/thread/ReservedThreadExecutor;
            1    9     1  pending  I
            2    9     2     size  I
           10   11     1        e  Ljava/util/concurrent/RejectedExecutionException;
      Exception table:
        from    to  target  type
           0     3       9  Class java.util.concurrent.RejectedExecutionException
           4     8       9  Class java.util.concurrent.RejectedExecutionException

  public java.lang.String toString();
    descriptor: ()Ljava/lang/String;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.ReservedThreadExecutor this
         0: .line 241
            ldc "%s@%x{s=%d/%d,p=%d}"
            iconst_5
            anewarray java.lang.Object
            dup
            iconst_0
         1: .line 242
            aload 0 /* this */
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            invokevirtual java.lang.Class.getSimpleName:()Ljava/lang/String;
            aastore
            dup
            iconst_1
         2: .line 243
            aload 0 /* this */
            invokevirtual java.lang.Object.hashCode:()I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            dup
            iconst_2
         3: .line 244
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._size:Ljava/util/concurrent/atomic/AtomicInteger;
            invokevirtual java.util.concurrent.atomic.AtomicInteger.get:()I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            dup
            iconst_3
         4: .line 245
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._capacity:I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            dup
            iconst_4
         5: .line 246
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ReservedThreadExecutor._pending:Ljava/util/concurrent/atomic/AtomicInteger;
            invokevirtual java.util.concurrent.atomic.AtomicInteger.get:()I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
         6: .line 241
            invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
            areturn
        end local 0 // org.eclipse.jetty.util.thread.ReservedThreadExecutor this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    7     0  this  Lorg/eclipse/jetty/util/thread/ReservedThreadExecutor;
}
SourceFile: "ReservedThreadExecutor.java"
NestMembers:
  org.eclipse.jetty.util.thread.ReservedThreadExecutor$1  org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread
InnerClasses:
  org.eclipse.jetty.util.thread.ReservedThreadExecutor$1
  private ReservedThread = org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread of org.eclipse.jetty.util.thread.ReservedThreadExecutor
  public abstract SizedThreadPool = org.eclipse.jetty.util.thread.ThreadPool$SizedThreadPool of org.eclipse.jetty.util.thread.ThreadPool
  public abstract Lease = org.eclipse.jetty.util.thread.ThreadPoolBudget$Lease of org.eclipse.jetty.util.thread.ThreadPoolBudget
    RuntimeVisibleAnnotations: 
      org.eclipse.jetty.util.annotation.ManagedObject(value = "A pool for reserved threads")
/

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