org.eclipse.jetty/jetty-util/11.0.0 : org/eclipse/jetty/util/thread/ThreadPoolBudget.class

ThreadPoolBudget
https://eclipse.org/jetty/jetty-util: 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)
Ludovic Orban (Webtide, LLC)
public class org.eclipse.jetty.util.thread.ThreadPoolBudget
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.eclipse.jetty.util.thread.ThreadPoolBudget
  super_class: java.lang.Object
{
  static final org.slf4j.Logger LOG;
    descriptor: Lorg/slf4j/Logger;
    flags: (0x0018) ACC_STATIC, ACC_FINAL

  private static final org.eclipse.jetty.util.thread.ThreadPoolBudget$Lease NOOP_LEASE;
    descriptor: Lorg/eclipse/jetty/util/thread/ThreadPoolBudget$Lease;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private final java.util.Set<org.eclipse.jetty.util.thread.ThreadPoolBudget$Leased> leases;
    descriptor: Ljava/util/Set;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/Set<Lorg/eclipse/jetty/util/thread/ThreadPoolBudget$Leased;>;

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

  private final org.eclipse.jetty.util.thread.ThreadPool$SizedThreadPool pool;
    descriptor: Lorg/eclipse/jetty/util/thread/ThreadPool$SizedThreadPool;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

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

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=2, locals=0, args_size=0
         0: .line 37
            ldc Lorg/eclipse/jetty/util/thread/ThreadPoolBudget;
            invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
            putstatic org.eclipse.jetty.util.thread.ThreadPoolBudget.LOG:Lorg/slf4j/Logger;
         1: .line 72
            new org.eclipse.jetty.util.thread.ThreadPoolBudget$1
            dup
            invokespecial org.eclipse.jetty.util.thread.ThreadPoolBudget$1.<init>:()V
            putstatic org.eclipse.jetty.util.thread.ThreadPoolBudget.NOOP_LEASE:Lorg/eclipse/jetty/util/thread/ThreadPoolBudget$Lease;
         2: .line 84
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>(org.eclipse.jetty.util.thread.ThreadPool$SizedThreadPool);
    descriptor: (Lorg/eclipse/jetty/util/thread/ThreadPool$SizedThreadPool;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // org.eclipse.jetty.util.thread.ThreadPoolBudget this
        start local 1 // org.eclipse.jetty.util.thread.ThreadPool$SizedThreadPool pool
         0: .line 96
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 86
            aload 0 /* this */
            new java.util.concurrent.CopyOnWriteArraySet
            dup
            invokespecial java.util.concurrent.CopyOnWriteArraySet.<init>:()V
            putfield org.eclipse.jetty.util.thread.ThreadPoolBudget.leases:Ljava/util/Set;
         2: .line 87
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicBoolean
            dup
            invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:()V
            putfield org.eclipse.jetty.util.thread.ThreadPoolBudget.warned:Ljava/util/concurrent/atomic/AtomicBoolean;
         3: .line 98
            aload 0 /* this */
            aload 1 /* pool */
            putfield org.eclipse.jetty.util.thread.ThreadPoolBudget.pool:Lorg/eclipse/jetty/util/thread/ThreadPool$SizedThreadPool;
         4: .line 99
            aload 0 /* this */
            iconst_m1
            putfield org.eclipse.jetty.util.thread.ThreadPoolBudget.warnAt:I
         5: .line 100
            return
        end local 1 // org.eclipse.jetty.util.thread.ThreadPool$SizedThreadPool pool
        end local 0 // org.eclipse.jetty.util.thread.ThreadPoolBudget this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Lorg/eclipse/jetty/util/thread/ThreadPoolBudget;
            0    6     1  pool  Lorg/eclipse/jetty/util/thread/ThreadPool$SizedThreadPool;
    MethodParameters:
      Name  Flags
      pool  

  public org.eclipse.jetty.util.thread.ThreadPool$SizedThreadPool getSizedThreadPool();
    descriptor: ()Lorg/eclipse/jetty/util/thread/ThreadPool$SizedThreadPool;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.ThreadPoolBudget this
         0: .line 104
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ThreadPoolBudget.pool:Lorg/eclipse/jetty/util/thread/ThreadPool$SizedThreadPool;
            areturn
        end local 0 // org.eclipse.jetty.util.thread.ThreadPoolBudget this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/util/thread/ThreadPoolBudget;

  public void reset();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.ThreadPoolBudget this
         0: .line 109
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ThreadPoolBudget.leases:Ljava/util/Set;
            invokeinterface java.util.Set.clear:()V
         1: .line 110
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ThreadPoolBudget.warned:Ljava/util/concurrent/atomic/AtomicBoolean;
            iconst_0
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.set:(Z)V
         2: .line 111
            return
        end local 0 // org.eclipse.jetty.util.thread.ThreadPoolBudget this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lorg/eclipse/jetty/util/thread/ThreadPoolBudget;

  public org.eclipse.jetty.util.thread.ThreadPoolBudget$Lease leaseTo(java.lang.Object, int);
    descriptor: (Ljava/lang/Object;I)Lorg/eclipse/jetty/util/thread/ThreadPoolBudget$Lease;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=5, args_size=3
        start local 0 // org.eclipse.jetty.util.thread.ThreadPoolBudget this
        start local 1 // java.lang.Object leasee
        start local 2 // int threads
         0: .line 115
            new org.eclipse.jetty.util.thread.ThreadPoolBudget$Leased
            dup
            aload 0 /* this */
            aload 1 /* leasee */
            iload 2 /* threads */
            invokespecial org.eclipse.jetty.util.thread.ThreadPoolBudget$Leased.<init>:(Lorg/eclipse/jetty/util/thread/ThreadPoolBudget;Ljava/lang/Object;I)V
            astore 3 /* lease */
        start local 3 // org.eclipse.jetty.util.thread.ThreadPoolBudget$Leased lease
         1: .line 116
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ThreadPoolBudget.leases:Ljava/util/Set;
            aload 3 /* lease */
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
         2: .line 119
            aload 0 /* this */
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ThreadPoolBudget.pool:Lorg/eclipse/jetty/util/thread/ThreadPool$SizedThreadPool;
            invokeinterface org.eclipse.jetty.util.thread.ThreadPool$SizedThreadPool.getMaxThreads:()I
            invokevirtual org.eclipse.jetty.util.thread.ThreadPoolBudget.check:(I)Z
            pop
         3: .line 120
            aload 3 /* lease */
         4: areturn
         5: .line 122
      StackMap locals: org.eclipse.jetty.util.thread.ThreadPoolBudget java.lang.Object int org.eclipse.jetty.util.thread.ThreadPoolBudget$Leased
      StackMap stack: java.lang.IllegalStateException
            astore 4 /* e */
        start local 4 // java.lang.IllegalStateException e
         6: .line 124
            aload 3 /* lease */
            invokevirtual org.eclipse.jetty.util.thread.ThreadPoolBudget$Leased.close:()V
         7: .line 125
            aload 4 /* e */
            athrow
        end local 4 // java.lang.IllegalStateException e
        end local 3 // org.eclipse.jetty.util.thread.ThreadPoolBudget$Leased lease
        end local 2 // int threads
        end local 1 // java.lang.Object leasee
        end local 0 // org.eclipse.jetty.util.thread.ThreadPoolBudget this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    8     0     this  Lorg/eclipse/jetty/util/thread/ThreadPoolBudget;
            0    8     1   leasee  Ljava/lang/Object;
            0    8     2  threads  I
            1    8     3    lease  Lorg/eclipse/jetty/util/thread/ThreadPoolBudget$Leased;
            6    8     4        e  Ljava/lang/IllegalStateException;
      Exception table:
        from    to  target  type
           2     4       5  Class java.lang.IllegalStateException
    MethodParameters:
         Name  Flags
      leasee   
      threads  

  public boolean check(int);
    descriptor: (I)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=4, args_size=2
        start local 0 // org.eclipse.jetty.util.thread.ThreadPoolBudget this
        start local 1 // int maxThreads
         0: .line 138
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ThreadPoolBudget.leases:Ljava/util/Set;
            invokeinterface java.util.Set.stream:()Ljava/util/stream/Stream;
         1: .line 139
            invokedynamic applyAsInt()Ljava/util/function/ToIntFunction;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)I
                  org/eclipse/jetty/util/thread/ThreadPoolBudget$Lease.getThreads()I (9 itf)
                  (Lorg/eclipse/jetty/util/thread/ThreadPoolBudget$Leased;)I
            invokeinterface java.util.stream.Stream.mapToInt:(Ljava/util/function/ToIntFunction;)Ljava/util/stream/IntStream;
         2: .line 140
            invokeinterface java.util.stream.IntStream.sum:()I
         3: .line 138
            istore 2 /* required */
        start local 2 // int required
         4: .line 141
            iload 1 /* maxThreads */
            iload 2 /* required */
            isub
            istore 3 /* left */
        start local 3 // int left
         5: .line 142
            iload 3 /* left */
            ifgt 8
         6: .line 144
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.util.thread.ThreadPoolBudget.printInfoOnLeases:()V
         7: .line 145
            new java.lang.IllegalStateException
            dup
            ldc "Insufficient configured threads: required=%d < max=%d for %s"
            iconst_3
            anewarray java.lang.Object
            dup
            iconst_0
            iload 2 /* required */
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            dup
            iconst_1
            iload 1 /* maxThreads */
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            dup
            iconst_2
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ThreadPoolBudget.pool:Lorg/eclipse/jetty/util/thread/ThreadPool$SizedThreadPool;
            aastore
            invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         8: .line 148
      StackMap locals: int int
      StackMap stack:
            iload 3 /* left */
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ThreadPoolBudget.warnAt:I
            if_icmpge 13
         9: .line 150
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ThreadPoolBudget.warned:Ljava/util/concurrent/atomic/AtomicBoolean;
            iconst_0
            iconst_1
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.compareAndSet:(ZZ)Z
            ifeq 12
        10: .line 152
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.util.thread.ThreadPoolBudget.printInfoOnLeases:()V
        11: .line 153
            getstatic org.eclipse.jetty.util.thread.ThreadPoolBudget.LOG:Lorg/slf4j/Logger;
            ldc "Low configured threads: (max={} - required={})={} < warnAt={} for {}"
            iconst_5
            anewarray java.lang.Object
            dup
            iconst_0
            iload 1 /* maxThreads */
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            dup
            iconst_1
            iload 2 /* required */
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            dup
            iconst_2
            iload 3 /* left */
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            dup
            iconst_3
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ThreadPoolBudget.warnAt:I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            dup
            iconst_4
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ThreadPoolBudget.pool:Lorg/eclipse/jetty/util/thread/ThreadPool$SizedThreadPool;
            aastore
            invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;[Ljava/lang/Object;)V
        12: .line 155
      StackMap locals:
      StackMap stack:
            iconst_0
            ireturn
        13: .line 157
      StackMap locals:
      StackMap stack:
            iconst_1
            ireturn
        end local 3 // int left
        end local 2 // int required
        end local 1 // int maxThreads
        end local 0 // org.eclipse.jetty.util.thread.ThreadPoolBudget this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   14     0        this  Lorg/eclipse/jetty/util/thread/ThreadPoolBudget;
            0   14     1  maxThreads  I
            4   14     2    required  I
            5   14     3        left  I
    Exceptions:
      throws java.lang.IllegalStateException
    MethodParameters:
            Name  Flags
      maxThreads  

  private void printInfoOnLeases();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.ThreadPoolBudget this
         0: .line 162
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ThreadPoolBudget.leases:Ljava/util/Set;
            aload 0 /* this */
            invokedynamic accept(Lorg/eclipse/jetty/util/thread/ThreadPoolBudget;)Ljava/util/function/Consumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  org/eclipse/jetty/util/thread/ThreadPoolBudget.lambda$1(Lorg/eclipse/jetty/util/thread/ThreadPoolBudget$Leased;)V (7)
                  (Lorg/eclipse/jetty/util/thread/ThreadPoolBudget$Leased;)V
            invokeinterface java.util.Set.forEach:(Ljava/util/function/Consumer;)V
         1: .line 163
            return
        end local 0 // org.eclipse.jetty.util.thread.ThreadPoolBudget this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/eclipse/jetty/util/thread/ThreadPoolBudget;

  public static org.eclipse.jetty.util.thread.ThreadPoolBudget$Lease leaseFrom(java.util.concurrent.Executor, java.lang.Object, int);
    descriptor: (Ljava/util/concurrent/Executor;Ljava/lang/Object;I)Lorg/eclipse/jetty/util/thread/ThreadPoolBudget$Lease;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=4, args_size=3
        start local 0 // java.util.concurrent.Executor executor
        start local 1 // java.lang.Object leasee
        start local 2 // int threads
         0: .line 167
            aload 0 /* executor */
            instanceof org.eclipse.jetty.util.thread.ThreadPool$SizedThreadPool
            ifeq 4
         1: .line 169
            aload 0 /* executor */
            checkcast org.eclipse.jetty.util.thread.ThreadPool$SizedThreadPool
            invokeinterface org.eclipse.jetty.util.thread.ThreadPool$SizedThreadPool.getThreadPoolBudget:()Lorg/eclipse/jetty/util/thread/ThreadPoolBudget;
            astore 3 /* budget */
        start local 3 // org.eclipse.jetty.util.thread.ThreadPoolBudget budget
         2: .line 170
            aload 3 /* budget */
            ifnull 4
         3: .line 171
            aload 3 /* budget */
            aload 1 /* leasee */
            iload 2 /* threads */
            invokevirtual org.eclipse.jetty.util.thread.ThreadPoolBudget.leaseTo:(Ljava/lang/Object;I)Lorg/eclipse/jetty/util/thread/ThreadPoolBudget$Lease;
            areturn
        end local 3 // org.eclipse.jetty.util.thread.ThreadPoolBudget budget
         4: .line 173
      StackMap locals:
      StackMap stack:
            getstatic org.eclipse.jetty.util.thread.ThreadPoolBudget.NOOP_LEASE:Lorg/eclipse/jetty/util/thread/ThreadPoolBudget$Lease;
            areturn
        end local 2 // int threads
        end local 1 // java.lang.Object leasee
        end local 0 // java.util.concurrent.Executor executor
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    5     0  executor  Ljava/util/concurrent/Executor;
            0    5     1    leasee  Ljava/lang/Object;
            0    5     2   threads  I
            2    4     3    budget  Lorg/eclipse/jetty/util/thread/ThreadPoolBudget;
    MethodParameters:
          Name  Flags
      executor  
      leasee    
      threads   

  private void lambda$1(org.eclipse.jetty.util.thread.ThreadPoolBudget$Leased);
    descriptor: (Lorg/eclipse/jetty/util/thread/ThreadPoolBudget$Leased;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=6, locals=2, args_size=2
        start local 0 // org.eclipse.jetty.util.thread.ThreadPoolBudget this
        start local 1 // org.eclipse.jetty.util.thread.ThreadPoolBudget$Leased lease
         0: .line 162
            getstatic org.eclipse.jetty.util.thread.ThreadPoolBudget.LOG:Lorg/slf4j/Logger;
            ldc "{} requires {} threads from {}"
            iconst_3
            anewarray java.lang.Object
            dup
            iconst_0
            aload 1 /* lease */
            getfield org.eclipse.jetty.util.thread.ThreadPoolBudget$Leased.leasee:Ljava/lang/Object;
            aastore
            dup
            iconst_1
            aload 1 /* lease */
            invokevirtual org.eclipse.jetty.util.thread.ThreadPoolBudget$Leased.getThreads:()I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            dup
            iconst_2
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.ThreadPoolBudget.pool:Lorg/eclipse/jetty/util/thread/ThreadPool$SizedThreadPool;
            aastore
            invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;[Ljava/lang/Object;)V
            return
        end local 1 // org.eclipse.jetty.util.thread.ThreadPoolBudget$Leased lease
        end local 0 // org.eclipse.jetty.util.thread.ThreadPoolBudget this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    1     0   this  Lorg/eclipse/jetty/util/thread/ThreadPoolBudget;
            0    1     1  lease  Lorg/eclipse/jetty/util/thread/ThreadPoolBudget$Leased;
}
SourceFile: "ThreadPoolBudget.java"
NestMembers:
  org.eclipse.jetty.util.thread.ThreadPoolBudget$1  org.eclipse.jetty.util.thread.ThreadPoolBudget$Lease  org.eclipse.jetty.util.thread.ThreadPoolBudget$Leased
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
  public abstract SizedThreadPool = org.eclipse.jetty.util.thread.ThreadPool$SizedThreadPool of org.eclipse.jetty.util.thread.ThreadPool
  org.eclipse.jetty.util.thread.ThreadPoolBudget$1
  public abstract Lease = org.eclipse.jetty.util.thread.ThreadPoolBudget$Lease of org.eclipse.jetty.util.thread.ThreadPoolBudget
  public Leased = org.eclipse.jetty.util.thread.ThreadPoolBudget$Leased of org.eclipse.jetty.util.thread.ThreadPoolBudget
/

org.eclipse.jetty/ jetty-util/ 11.0.0/ org/eclipse/jetty/util/thread/ThreadPoolBudget.class
