public class org.eclipse.jetty.util.thread.QueuedThreadPool extends org.eclipse.jetty.util.component.ContainerLifeCycle implements org.eclipse.jetty.util.thread.ThreadPool$SizedThreadPool, org.eclipse.jetty.util.component.Dumpable, 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.QueuedThreadPool
super_class: org.eclipse.jetty.util.component.ContainerLifeCycle
{
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 java.lang.Runnable NOOP;
descriptor: Ljava/lang/Runnable;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
private final org.eclipse.jetty.util.AtomicBiInteger _counts;
descriptor: Lorg/eclipse/jetty/util/AtomicBiInteger;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.atomic.AtomicLong _lastShrink;
descriptor: Ljava/util/concurrent/atomic/AtomicLong;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.Set<java.lang.Thread> _threads;
descriptor: Ljava/util/Set;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Set<Ljava/lang/Thread;>;
private final java.lang.Object _joinLock;
descriptor: Ljava/lang/Object;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.BlockingQueue<java.lang.Runnable> _jobs;
descriptor: Ljava/util/concurrent/BlockingQueue;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/concurrent/BlockingQueue<Ljava/lang/Runnable;>;
private final java.lang.ThreadGroup _threadGroup;
descriptor: Ljava/lang/ThreadGroup;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private java.lang.String _name;
descriptor: Ljava/lang/String;
flags: (0x0002) ACC_PRIVATE
private int _idleTimeout;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private int _maxThreads;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private int _minThreads;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private int _reservedThreads;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private org.eclipse.jetty.util.thread.TryExecutor _tryExecutor;
descriptor: Lorg/eclipse/jetty/util/thread/TryExecutor;
flags: (0x0002) ACC_PRIVATE
private int _priority;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private boolean _daemon;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private boolean _detailedDump;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private int _lowThreadsThreshold;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private org.eclipse.jetty.util.thread.ThreadPoolBudget _budget;
descriptor: Lorg/eclipse/jetty/util/thread/ThreadPoolBudget;
flags: (0x0002) ACC_PRIVATE
private final java.lang.Runnable _runnable;
descriptor: Ljava/lang/Runnable;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
invokestatic org.eclipse.jetty.util.log.Log.getLogger:(Ljava/lang/Class;)Lorg/eclipse/jetty/util/log/Logger;
putstatic org.eclipse.jetty.util.thread.QueuedThreadPool.LOG:Lorg/eclipse/jetty/util/log/Logger;
1: invokedynamic run()Ljava/lang/Runnable;
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:
()V
org/eclipse/jetty/util/thread/QueuedThreadPool.lambda$0()V (6)
()V
putstatic org.eclipse.jetty.util.thread.QueuedThreadPool.NOOP:Ljava/lang/Runnable;
2: return
LocalVariableTable:
Start End Slot Name Signature
public void <init>();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
sipush 200
invokespecial org.eclipse.jetty.util.thread.QueuedThreadPool.<init>:(I)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
public void <init>(int);
descriptor: (I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iload 1
bipush 8
iload 1
invokestatic java.lang.Math.min:(II)I
invokespecial org.eclipse.jetty.util.thread.QueuedThreadPool.<init>:(II)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
0 2 1 maxThreads I
RuntimeVisibleParameterAnnotations:
0:
org.eclipse.jetty.util.annotation.Name(value = "maxThreads")
MethodParameters:
Name Flags
maxThreads
public void <init>(int, int);
descriptor: (II)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
iload 1
iload 2
ldc 60000
invokespecial org.eclipse.jetty.util.thread.QueuedThreadPool.<init>:(III)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
0 2 1 maxThreads I
0 2 2 minThreads I
RuntimeVisibleParameterAnnotations:
0:
org.eclipse.jetty.util.annotation.Name(value = "maxThreads")
1:
org.eclipse.jetty.util.annotation.Name(value = "minThreads")
MethodParameters:
Name Flags
maxThreads
minThreads
public void <init>(int, int, java.util.concurrent.BlockingQueue<java.lang.Runnable>);
descriptor: (IILjava/util/concurrent/BlockingQueue;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
iload 1
iload 2
ldc 60000
iconst_m1
aload 3
aconst_null
invokespecial org.eclipse.jetty.util.thread.QueuedThreadPool.<init>:(IIIILjava/util/concurrent/BlockingQueue;Ljava/lang/ThreadGroup;)V
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
0 2 1 maxThreads I
0 2 2 minThreads I
0 2 3 queue Ljava/util/concurrent/BlockingQueue<Ljava/lang/Runnable;>;
Signature: (IILjava/util/concurrent/BlockingQueue<Ljava/lang/Runnable;>;)V
RuntimeVisibleParameterAnnotations:
0:
org.eclipse.jetty.util.annotation.Name(value = "maxThreads")
1:
org.eclipse.jetty.util.annotation.Name(value = "minThreads")
2:
org.eclipse.jetty.util.annotation.Name(value = "queue")
MethodParameters:
Name Flags
maxThreads
minThreads
queue
public void <init>(int, int, int);
descriptor: (III)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
iload 1
iload 2
iload 3
aconst_null
invokespecial org.eclipse.jetty.util.thread.QueuedThreadPool.<init>:(IIILjava/util/concurrent/BlockingQueue;)V
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
0 2 1 maxThreads I
0 2 2 minThreads I
0 2 3 idleTimeout I
RuntimeVisibleParameterAnnotations:
0:
org.eclipse.jetty.util.annotation.Name(value = "maxThreads")
1:
org.eclipse.jetty.util.annotation.Name(value = "minThreads")
2:
org.eclipse.jetty.util.annotation.Name(value = "idleTimeout")
MethodParameters:
Name Flags
maxThreads
minThreads
idleTimeout
public void <init>(int, int, int, java.util.concurrent.BlockingQueue<java.lang.Runnable>);
descriptor: (IIILjava/util/concurrent/BlockingQueue;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
iload 1
iload 2
iload 3
aload 4
aconst_null
invokespecial org.eclipse.jetty.util.thread.QueuedThreadPool.<init>:(IIILjava/util/concurrent/BlockingQueue;Ljava/lang/ThreadGroup;)V
1: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
0 2 1 maxThreads I
0 2 2 minThreads I
0 2 3 idleTimeout I
0 2 4 queue Ljava/util/concurrent/BlockingQueue<Ljava/lang/Runnable;>;
Signature: (IIILjava/util/concurrent/BlockingQueue<Ljava/lang/Runnable;>;)V
RuntimeVisibleParameterAnnotations:
0:
org.eclipse.jetty.util.annotation.Name(value = "maxThreads")
1:
org.eclipse.jetty.util.annotation.Name(value = "minThreads")
2:
org.eclipse.jetty.util.annotation.Name(value = "idleTimeout")
3:
org.eclipse.jetty.util.annotation.Name(value = "queue")
MethodParameters:
Name Flags
maxThreads
minThreads
idleTimeout
queue
public void <init>(int, int, int, java.util.concurrent.BlockingQueue<java.lang.Runnable>, java.lang.ThreadGroup);
descriptor: (IIILjava/util/concurrent/BlockingQueue;Ljava/lang/ThreadGroup;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=6, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
iload 1
iload 2
iload 3
iconst_m1
aload 4
aload 5
invokespecial org.eclipse.jetty.util.thread.QueuedThreadPool.<init>:(IIIILjava/util/concurrent/BlockingQueue;Ljava/lang/ThreadGroup;)V
1: return
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
0 2 1 maxThreads I
0 2 2 minThreads I
0 2 3 idleTimeout I
0 2 4 queue Ljava/util/concurrent/BlockingQueue<Ljava/lang/Runnable;>;
0 2 5 threadGroup Ljava/lang/ThreadGroup;
Signature: (IIILjava/util/concurrent/BlockingQueue<Ljava/lang/Runnable;>;Ljava/lang/ThreadGroup;)V
RuntimeVisibleParameterAnnotations:
0:
org.eclipse.jetty.util.annotation.Name(value = "maxThreads")
1:
org.eclipse.jetty.util.annotation.Name(value = "minThreads")
2:
org.eclipse.jetty.util.annotation.Name(value = "idleTimeout")
3:
org.eclipse.jetty.util.annotation.Name(value = "queue")
4:
org.eclipse.jetty.util.annotation.Name(value = "threadGroup")
MethodParameters:
Name Flags
maxThreads
minThreads
idleTimeout
queue
threadGroup
public void <init>(int, int, int, int, java.util.concurrent.BlockingQueue<java.lang.Runnable>, java.lang.ThreadGroup);
descriptor: (IIIILjava/util/concurrent/BlockingQueue;Ljava/lang/ThreadGroup;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=8, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: aload 0
invokespecial org.eclipse.jetty.util.component.ContainerLifeCycle.<init>:()V
1: aload 0
new org.eclipse.jetty.util.AtomicBiInteger
dup
ldc -2147483648
iconst_0
invokespecial org.eclipse.jetty.util.AtomicBiInteger.<init>:(II)V
putfield org.eclipse.jetty.util.thread.QueuedThreadPool._counts:Lorg/eclipse/jetty/util/AtomicBiInteger;
2: aload 0
new java.util.concurrent.atomic.AtomicLong
dup
invokespecial java.util.concurrent.atomic.AtomicLong.<init>:()V
putfield org.eclipse.jetty.util.thread.QueuedThreadPool._lastShrink:Ljava/util/concurrent/atomic/AtomicLong;
3: aload 0
invokestatic java.util.concurrent.ConcurrentHashMap.newKeySet:()Ljava/util/concurrent/ConcurrentHashMap$KeySetView;
putfield org.eclipse.jetty.util.thread.QueuedThreadPool._threads:Ljava/util/Set;
4: aload 0
new java.lang.Object
dup
invokespecial java.lang.Object.<init>:()V
putfield org.eclipse.jetty.util.thread.QueuedThreadPool._joinLock:Ljava/lang/Object;
5: aload 0
new java.lang.StringBuilder
dup
ldc "qtp"
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual java.lang.Object.hashCode:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
putfield org.eclipse.jetty.util.thread.QueuedThreadPool._name:Ljava/lang/String;
6: aload 0
iconst_m1
putfield org.eclipse.jetty.util.thread.QueuedThreadPool._reservedThreads:I
7: aload 0
getstatic org.eclipse.jetty.util.thread.TryExecutor.NO_TRY:Lorg/eclipse/jetty/util/thread/TryExecutor;
putfield org.eclipse.jetty.util.thread.QueuedThreadPool._tryExecutor:Lorg/eclipse/jetty/util/thread/TryExecutor;
8: aload 0
iconst_5
putfield org.eclipse.jetty.util.thread.QueuedThreadPool._priority:I
9: aload 0
iconst_0
putfield org.eclipse.jetty.util.thread.QueuedThreadPool._daemon:Z
10: aload 0
iconst_0
putfield org.eclipse.jetty.util.thread.QueuedThreadPool._detailedDump:Z
11: aload 0
iconst_1
putfield org.eclipse.jetty.util.thread.QueuedThreadPool._lowThreadsThreshold:I
12: aload 0
new org.eclipse.jetty.util.thread.QueuedThreadPool$Runner
dup
aload 0
invokespecial org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.<init>:(Lorg/eclipse/jetty/util/thread/QueuedThreadPool;)V
putfield org.eclipse.jetty.util.thread.QueuedThreadPool._runnable:Ljava/lang/Runnable;
13: iload 1
iload 2
if_icmpge 15
14: new java.lang.IllegalArgumentException
dup
new java.lang.StringBuilder
dup
ldc "max threads ("
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
iload 1
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc ") less than min threads ("
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
iload 2
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc ")"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
15: StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool int int int int java.util.concurrent.BlockingQueue java.lang.ThreadGroup
StackMap stack:
aload 0
iload 2
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.setMinThreads:(I)V
16: aload 0
iload 1
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.setMaxThreads:(I)V
17: aload 0
iload 3
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.setIdleTimeout:(I)V
18: aload 0
ldc 5000
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.setStopTimeout:(J)V
19: aload 0
iload 4
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.setReservedThreads:(I)V
20: aload 5
ifnonnull 23
21: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._minThreads:I
bipush 8
invokestatic java.lang.Math.max:(II)I
sipush 1024
imul
istore 7
start local 7 22: new org.eclipse.jetty.util.BlockingArrayQueue
dup
iload 7
iload 7
invokespecial org.eclipse.jetty.util.BlockingArrayQueue.<init>:(II)V
astore 5
end local 7 23: StackMap locals:
StackMap stack:
aload 0
aload 5
putfield org.eclipse.jetty.util.thread.QueuedThreadPool._jobs:Ljava/util/concurrent/BlockingQueue;
24: aload 0
aload 6
putfield org.eclipse.jetty.util.thread.QueuedThreadPool._threadGroup:Ljava/lang/ThreadGroup;
25: aload 0
new org.eclipse.jetty.util.thread.ThreadPoolBudget
dup
aload 0
invokespecial org.eclipse.jetty.util.thread.ThreadPoolBudget.<init>:(Lorg/eclipse/jetty/util/thread/ThreadPool$SizedThreadPool;)V
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.setThreadPoolBudget:(Lorg/eclipse/jetty/util/thread/ThreadPoolBudget;)V
26: return
end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 27 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
0 27 1 maxThreads I
0 27 2 minThreads I
0 27 3 idleTimeout I
0 27 4 reservedThreads I
0 27 5 queue Ljava/util/concurrent/BlockingQueue<Ljava/lang/Runnable;>;
0 27 6 threadGroup Ljava/lang/ThreadGroup;
22 23 7 capacity I
Signature: (IIIILjava/util/concurrent/BlockingQueue<Ljava/lang/Runnable;>;Ljava/lang/ThreadGroup;)V
RuntimeVisibleParameterAnnotations:
0:
org.eclipse.jetty.util.annotation.Name(value = "maxThreads")
1:
org.eclipse.jetty.util.annotation.Name(value = "minThreads")
2:
org.eclipse.jetty.util.annotation.Name(value = "idleTimeout")
3:
org.eclipse.jetty.util.annotation.Name(value = "reservedThreads")
4:
org.eclipse.jetty.util.annotation.Name(value = "queue")
5:
org.eclipse.jetty.util.annotation.Name(value = "threadGroup")
MethodParameters:
Name Flags
maxThreads
minThreads
idleTimeout
reservedThreads
queue
threadGroup
public org.eclipse.jetty.util.thread.ThreadPoolBudget getThreadPoolBudget();
descriptor: ()Lorg/eclipse/jetty/util/thread/ThreadPoolBudget;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._budget:Lorg/eclipse/jetty/util/thread/ThreadPoolBudget;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
public void setThreadPoolBudget(org.eclipse.jetty.util.thread.ThreadPoolBudget);
descriptor: (Lorg/eclipse/jetty/util/thread/ThreadPoolBudget;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ifnull 2
aload 1
invokevirtual org.eclipse.jetty.util.thread.ThreadPoolBudget.getSizedThreadPool:()Lorg/eclipse/jetty/util/thread/ThreadPool$SizedThreadPool;
aload 0
if_acmpeq 2
1: new java.lang.IllegalArgumentException
dup
invokespecial java.lang.IllegalArgumentException.<init>:()V
athrow
2: StackMap locals:
StackMap stack:
aload 0
aload 1
putfield org.eclipse.jetty.util.thread.QueuedThreadPool._budget:Lorg/eclipse/jetty/util/thread/ThreadPoolBudget;
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
0 4 1 budget Lorg/eclipse/jetty/util/thread/ThreadPoolBudget;
MethodParameters:
Name Flags
budget
protected void doStart();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=4, locals=2, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._reservedThreads:I
ifne 3
1: aload 0
getstatic org.eclipse.jetty.util.thread.QueuedThreadPool.NO_TRY:Lorg/eclipse/jetty/util/thread/TryExecutor;
putfield org.eclipse.jetty.util.thread.QueuedThreadPool._tryExecutor:Lorg/eclipse/jetty/util/thread/TryExecutor;
2: goto 6
3: StackMap locals:
StackMap stack:
new org.eclipse.jetty.util.thread.ReservedThreadExecutor
dup
aload 0
aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._reservedThreads:I
invokespecial org.eclipse.jetty.util.thread.ReservedThreadExecutor.<init>:(Ljava/util/concurrent/Executor;I)V
astore 1
start local 1 4: aload 1
aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._idleTimeout:I
i2l
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
invokevirtual org.eclipse.jetty.util.thread.ReservedThreadExecutor.setIdleTimeout:(JLjava/util/concurrent/TimeUnit;)V
5: aload 0
aload 1
putfield org.eclipse.jetty.util.thread.QueuedThreadPool._tryExecutor:Lorg/eclipse/jetty/util/thread/TryExecutor;
end local 1 6: StackMap locals:
StackMap stack:
aload 0
aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._tryExecutor:Lorg/eclipse/jetty/util/thread/TryExecutor;
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.addBean:(Ljava/lang/Object;)Z
pop
7: aload 0
invokespecial org.eclipse.jetty.util.component.ContainerLifeCycle.doStart:()V
8: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._counts:Lorg/eclipse/jetty/util/AtomicBiInteger;
iconst_0
iconst_0
invokevirtual org.eclipse.jetty.util.AtomicBiInteger.set:(II)V
9: aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.ensureThreads:()V
10: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
4 6 1 reserved Lorg/eclipse/jetty/util/thread/ReservedThreadExecutor;
Exceptions:
throws java.lang.Exception
protected void doStop();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=7, locals=12, args_size=1
start local 0 0: getstatic org.eclipse.jetty.util.thread.QueuedThreadPool.LOG:Lorg/eclipse/jetty/util/log/Logger;
invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
ifeq 2
1: getstatic org.eclipse.jetty.util.thread.QueuedThreadPool.LOG:Lorg/eclipse/jetty/util/log/Logger;
ldc "Stopping {}"
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
2: StackMap locals:
StackMap stack:
aload 0
aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._tryExecutor:Lorg/eclipse/jetty/util/thread/TryExecutor;
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.removeBean:(Ljava/lang/Object;)Z
pop
3: aload 0
getstatic org.eclipse.jetty.util.thread.TryExecutor.NO_TRY:Lorg/eclipse/jetty/util/thread/TryExecutor;
putfield org.eclipse.jetty.util.thread.QueuedThreadPool._tryExecutor:Lorg/eclipse/jetty/util/thread/TryExecutor;
4: aload 0
invokespecial org.eclipse.jetty.util.component.ContainerLifeCycle.doStop:()V
5: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._counts:Lorg/eclipse/jetty/util/AtomicBiInteger;
ldc -2147483648
invokevirtual org.eclipse.jetty.util.AtomicBiInteger.getAndSetHi:(I)I
istore 1
start local 1 6: aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.getStopTimeout:()J
lstore 2
start local 2 7: aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.getQueue:()Ljava/util/concurrent/BlockingQueue;
astore 4
start local 4 8: lload 2
lconst_0
lcmp
ifle 49
9: iconst_0
istore 5
start local 5 10: goto 13
11: StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool int long java.util.concurrent.BlockingQueue int
StackMap stack:
aload 4
getstatic org.eclipse.jetty.util.thread.QueuedThreadPool.NOOP:Ljava/lang/Runnable;
invokeinterface java.util.concurrent.BlockingQueue.offer:(Ljava/lang/Object;)Z
pop
12: iinc 5 1
StackMap locals:
StackMap stack:
13: iload 5
iload 1
if_icmplt 11
end local 5 14: aload 0
invokestatic java.lang.System.nanoTime:()J
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
lload 2
invokevirtual java.util.concurrent.TimeUnit.toNanos:(J)J
ldc 2
ldiv
ladd
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.joinThreads:(J)V
15: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._threads:Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 6
goto 20
StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool int long java.util.concurrent.BlockingQueue top java.util.Iterator
StackMap stack:
16: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.lang.Thread
astore 5
start local 5 17: getstatic org.eclipse.jetty.util.thread.QueuedThreadPool.LOG:Lorg/eclipse/jetty/util/log/Logger;
invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
ifeq 19
18: getstatic org.eclipse.jetty.util.thread.QueuedThreadPool.LOG:Lorg/eclipse/jetty/util/log/Logger;
ldc "Interrupting {}"
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 5
aastore
invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
19: StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool int long java.util.concurrent.BlockingQueue java.lang.Thread java.util.Iterator
StackMap stack:
aload 5
invokevirtual java.lang.Thread.interrupt:()V
end local 5 20: StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool int long java.util.concurrent.BlockingQueue top java.util.Iterator
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 16
21: aload 0
invokestatic java.lang.System.nanoTime:()J
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
lload 2
invokevirtual java.util.concurrent.TimeUnit.toNanos:(J)J
ldc 2
ldiv
ladd
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.joinThreads:(J)V
22: invokestatic java.lang.Thread.yield:()V
23: getstatic org.eclipse.jetty.util.thread.QueuedThreadPool.LOG:Lorg/eclipse/jetty/util/log/Logger;
invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
ifeq 35
24: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._threads:Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 6
goto 33
StackMap locals:
StackMap stack:
25: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.lang.Thread
astore 5
start local 5 26: new java.lang.StringBuilder
dup
invokespecial java.lang.StringBuilder.<init>:()V
astore 7
start local 7 27: aload 5
invokevirtual java.lang.Thread.getStackTrace:()[Ljava/lang/StackTraceElement;
dup
astore 11
arraylength
istore 10
iconst_0
istore 9
goto 31
StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool int long java.util.concurrent.BlockingQueue java.lang.Thread java.util.Iterator java.lang.StringBuilder top int int java.lang.StackTraceElement[]
StackMap stack:
28: aload 11
iload 9
aaload
astore 8
start local 8 29: aload 7
invokestatic java.lang.System.lineSeparator:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc "\tat "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 8
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
pop
end local 8 30: iinc 9 1
StackMap locals:
StackMap stack:
31: iload 9
iload 10
if_icmplt 28
32: getstatic org.eclipse.jetty.util.thread.QueuedThreadPool.LOG:Lorg/eclipse/jetty/util/log/Logger;
ldc "Couldn't stop {}{}"
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 5
aastore
dup
iconst_1
aload 7
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
aastore
invokeinterface org.eclipse.jetty.util.log.Logger.warn:(Ljava/lang/String;[Ljava/lang/Object;)V
end local 7 end local 5 33: StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool int long java.util.concurrent.BlockingQueue top java.util.Iterator
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 25
34: goto 49
35: StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool int long java.util.concurrent.BlockingQueue
StackMap stack:
aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._threads:Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 6
goto 38
StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool int long java.util.concurrent.BlockingQueue top java.util.Iterator
StackMap stack:
36: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.lang.Thread
astore 5
start local 5 37: getstatic org.eclipse.jetty.util.thread.QueuedThreadPool.LOG:Lorg/eclipse/jetty/util/log/Logger;
ldc "{} Couldn't stop {}"
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 5
aastore
invokeinterface org.eclipse.jetty.util.log.Logger.warn:(Ljava/lang/String;[Ljava/lang/Object;)V
end local 5 38: StackMap locals:
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 36
39: goto 49
40: StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool int long java.util.concurrent.BlockingQueue
StackMap stack:
aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._jobs:Ljava/util/concurrent/BlockingQueue;
invokeinterface java.util.concurrent.BlockingQueue.poll:()Ljava/lang/Object;
checkcast java.lang.Runnable
astore 5
start local 5 41: aload 5
instanceof java.io.Closeable
ifeq 47
42: aload 5
checkcast java.io.Closeable
invokeinterface java.io.Closeable.close:()V
43: goto 49
44: StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool int long java.util.concurrent.BlockingQueue java.lang.Runnable
StackMap stack: java.lang.Throwable
astore 6
start local 6 45: getstatic org.eclipse.jetty.util.thread.QueuedThreadPool.LOG:Lorg/eclipse/jetty/util/log/Logger;
aload 6
invokeinterface org.eclipse.jetty.util.log.Logger.warn:(Ljava/lang/Throwable;)V
end local 6 46: goto 49
47: StackMap locals:
StackMap stack:
aload 5
getstatic org.eclipse.jetty.util.thread.QueuedThreadPool.NOOP:Ljava/lang/Runnable;
if_acmpeq 49
48: getstatic org.eclipse.jetty.util.thread.QueuedThreadPool.LOG:Lorg/eclipse/jetty/util/log/Logger;
ldc "Stopped without executing or closing {}"
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 5
aastore
invokeinterface org.eclipse.jetty.util.log.Logger.warn:(Ljava/lang/String;[Ljava/lang/Object;)V
end local 5 49: StackMap locals:
StackMap stack:
aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._jobs:Ljava/util/concurrent/BlockingQueue;
invokeinterface java.util.concurrent.BlockingQueue.isEmpty:()Z
ifeq 40
50: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._budget:Lorg/eclipse/jetty/util/thread/ThreadPoolBudget;
ifnull 52
51: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._budget:Lorg/eclipse/jetty/util/thread/ThreadPoolBudget;
invokevirtual org.eclipse.jetty.util.thread.ThreadPoolBudget.reset:()V
52: StackMap locals:
StackMap stack:
aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._joinLock:Ljava/lang/Object;
dup
astore 5
monitorenter
53: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._joinLock:Ljava/lang/Object;
invokevirtual java.lang.Object.notifyAll:()V
54: aload 5
monitorexit
55: goto 58
StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool int long java.util.concurrent.BlockingQueue java.lang.Object
StackMap stack: java.lang.Throwable
56: aload 5
monitorexit
57: athrow
58: StackMap locals:
StackMap stack:
return
end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 59 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
6 59 1 threads I
7 59 2 timeout J
8 59 4 jobs Ljava/util/concurrent/BlockingQueue<Ljava/lang/Runnable;>;
10 14 5 i I
17 20 5 thread Ljava/lang/Thread;
26 33 5 unstopped Ljava/lang/Thread;
27 33 7 dmp Ljava/lang/StringBuilder;
29 30 8 element Ljava/lang/StackTraceElement;
37 38 5 unstopped Ljava/lang/Thread;
41 49 5 job Ljava/lang/Runnable;
45 46 6 t Ljava/lang/Throwable;
Exception table:
from to target type
42 43 44 Class java.lang.Throwable
53 55 56 any
56 57 56 any
Exceptions:
throws java.lang.Exception
private void joinThreads(long);
descriptor: (J)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=7, locals=7, args_size=2
start local 0 start local 1 0: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._threads:Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 4
goto 7
StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool long top java.util.Iterator
StackMap stack:
1: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.lang.Thread
astore 3
start local 3 2: getstatic java.util.concurrent.TimeUnit.NANOSECONDS:Ljava/util/concurrent/TimeUnit;
lload 1
invokestatic java.lang.System.nanoTime:()J
lsub
invokevirtual java.util.concurrent.TimeUnit.toMillis:(J)J
lstore 5
start local 5 3: getstatic org.eclipse.jetty.util.thread.QueuedThreadPool.LOG:Lorg/eclipse/jetty/util/log/Logger;
invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
ifeq 5
4: getstatic org.eclipse.jetty.util.thread.QueuedThreadPool.LOG:Lorg/eclipse/jetty/util/log/Logger;
ldc "Waiting for {} for {}"
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 3
aastore
dup
iconst_1
lload 5
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
aastore
invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
5: StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool long java.lang.Thread java.util.Iterator long
StackMap stack:
lload 5
lconst_0
lcmp
ifle 7
6: aload 3
lload 5
invokevirtual java.lang.Thread.join:(J)V
end local 5 end local 3 7: StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool long top java.util.Iterator
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
8: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
0 9 1 stopByNanos J
2 7 3 thread Ljava/lang/Thread;
3 7 5 canWait J
Exceptions:
throws java.lang.InterruptedException
MethodParameters:
Name Flags
stopByNanos
public void setDaemon(boolean);
descriptor: (Z)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iload 1
putfield org.eclipse.jetty.util.thread.QueuedThreadPool._daemon:Z
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
0 2 1 daemon Z
MethodParameters:
Name Flags
daemon
public void setIdleTimeout(int);
descriptor: (I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iload 1
putfield org.eclipse.jetty.util.thread.QueuedThreadPool._idleTimeout:I
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
0 2 1 idleTimeout I
MethodParameters:
Name Flags
idleTimeout
public void setMaxThreads(int);
descriptor: (I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._budget:Lorg/eclipse/jetty/util/thread/ThreadPoolBudget;
ifnull 2
1: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._budget:Lorg/eclipse/jetty/util/thread/ThreadPoolBudget;
iload 1
invokevirtual org.eclipse.jetty.util.thread.ThreadPoolBudget.check:(I)Z
pop
2: StackMap locals:
StackMap stack:
aload 0
iload 1
putfield org.eclipse.jetty.util.thread.QueuedThreadPool._maxThreads:I
3: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._minThreads:I
aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._maxThreads:I
if_icmple 5
4: aload 0
aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._maxThreads:I
putfield org.eclipse.jetty.util.thread.QueuedThreadPool._minThreads:I
5: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
0 6 1 maxThreads I
MethodParameters:
Name Flags
maxThreads
public void setMinThreads(int);
descriptor: (I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iload 1
putfield org.eclipse.jetty.util.thread.QueuedThreadPool._minThreads:I
1: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._minThreads:I
aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._maxThreads:I
if_icmple 3
2: aload 0
aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._minThreads:I
putfield org.eclipse.jetty.util.thread.QueuedThreadPool._maxThreads:I
3: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.isStarted:()Z
ifeq 5
4: aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.ensureThreads:()V
5: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
0 6 1 minThreads I
MethodParameters:
Name Flags
minThreads
public void setReservedThreads(int);
descriptor: (I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.isRunning:()Z
ifeq 2
1: new java.lang.IllegalStateException
dup
aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.getState:()Ljava/lang/String;
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aload 0
iload 1
putfield org.eclipse.jetty.util.thread.QueuedThreadPool._reservedThreads:I
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
0 4 1 reservedThreads I
MethodParameters:
Name Flags
reservedThreads
public void setName(java.lang.String);
descriptor: (Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.isRunning:()Z
ifeq 2
1: new java.lang.IllegalStateException
dup
ldc "started"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aload 0
aload 1
putfield org.eclipse.jetty.util.thread.QueuedThreadPool._name:Ljava/lang/String;
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
0 4 1 name Ljava/lang/String;
MethodParameters:
Name Flags
name
public void setThreadsPriority(int);
descriptor: (I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iload 1
putfield org.eclipse.jetty.util.thread.QueuedThreadPool._priority:I
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
0 2 1 priority I
MethodParameters:
Name Flags
priority
public int getIdleTimeout();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._idleTimeout:I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedAttribute(value = "maximum time a thread may be idle in ms")
public int getMaxThreads();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._maxThreads:I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedAttribute(value = "maximum number of threads in the pool")
public int getMinThreads();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._minThreads:I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedAttribute(value = "minimum number of threads in the pool")
public int getReservedThreads();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.isStarted:()Z
ifeq 4
1: aload 0
ldc Lorg/eclipse/jetty/util/thread/ReservedThreadExecutor;
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.getBean:(Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.eclipse.jetty.util.thread.ReservedThreadExecutor
astore 1
start local 1 2: aload 1
ifnull 4
3: aload 1
invokevirtual org.eclipse.jetty.util.thread.ReservedThreadExecutor.getCapacity:()I
ireturn
end local 1 4: StackMap locals:
StackMap stack:
aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._reservedThreads:I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
2 4 1 reservedThreadExecutor Lorg/eclipse/jetty/util/thread/ReservedThreadExecutor;
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedAttribute(value = "the number of reserved threads in the pool")
public java.lang.String getName();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._name:Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedAttribute(value = "name of the thread pool")
public int getThreadsPriority();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._priority:I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedAttribute(value = "priority of threads in the pool")
public int getQueueSize();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._jobs:Ljava/util/concurrent/BlockingQueue;
invokeinterface java.util.concurrent.BlockingQueue.size:()I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedAttribute(value = "size of the job queue")
public boolean isDaemon();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._daemon:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedAttribute(value = "thread pool uses daemon threads")
public boolean isDetailedDump();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._detailedDump:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedAttribute(value = "reports additional details in the dump")
public void setDetailedDump(boolean);
descriptor: (Z)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iload 1
putfield org.eclipse.jetty.util.thread.QueuedThreadPool._detailedDump:Z
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
0 2 1 detailedDump Z
MethodParameters:
Name Flags
detailedDump
public int getLowThreadsThreshold();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._lowThreadsThreshold:I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedAttribute(value = "threshold at which the pool is low on threads")
public void setLowThreadsThreshold(int);
descriptor: (I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iload 1
putfield org.eclipse.jetty.util.thread.QueuedThreadPool._lowThreadsThreshold:I
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
0 2 1 lowThreadsThreshold I
MethodParameters:
Name Flags
lowThreadsThreshold
public void execute(java.lang.Runnable);
descriptor: (Ljava/lang/Runnable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=7, args_size=2
start local 0 start local 1 0: StackMap locals:
StackMap stack:
aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._counts:Lorg/eclipse/jetty/util/AtomicBiInteger;
invokevirtual org.eclipse.jetty.util.AtomicBiInteger.get:()J
lstore 3
start local 3 1: lload 3
invokestatic org.eclipse.jetty.util.AtomicBiInteger.getHi:(J)I
istore 5
start local 5 2: iload 5
ldc -2147483648
if_icmpne 4
3: new java.util.concurrent.RejectedExecutionException
dup
aload 1
invokevirtual java.lang.Object.toString:()Ljava/lang/String;
invokespecial java.util.concurrent.RejectedExecutionException.<init>:(Ljava/lang/String;)V
athrow
4: StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool java.lang.Runnable top long int
StackMap stack:
lload 3
invokestatic org.eclipse.jetty.util.AtomicBiInteger.getLo:(J)I
istore 6
start local 6 5: iload 6
ifgt 6
iload 5
aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._maxThreads:I
if_icmpge 6
iconst_1
goto 7
StackMap locals: int
StackMap stack:
6: iconst_0
StackMap locals:
StackMap stack: int
7: istore 2
start local 2 8: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._counts:Lorg/eclipse/jetty/util/AtomicBiInteger;
lload 3
iload 5
iload 2
ifeq 9
iconst_1
goto 10
StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool java.lang.Runnable int long int int
StackMap stack: org.eclipse.jetty.util.AtomicBiInteger long int
9: iconst_0
StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool java.lang.Runnable int long int int
StackMap stack: org.eclipse.jetty.util.AtomicBiInteger long int int
10: iadd
iload 6
iconst_1
isub
invokevirtual org.eclipse.jetty.util.AtomicBiInteger.compareAndSet:(JII)Z
ifne 12
end local 6 end local 5 end local 3 end local 2 11: goto 0
start local 2 12: StackMap locals:
StackMap stack:
aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._jobs:Ljava/util/concurrent/BlockingQueue;
aload 1
invokeinterface java.util.concurrent.BlockingQueue.offer:(Ljava/lang/Object;)Z
ifne 18
13: aload 0
iload 2
ifeq 14
iconst_m1
goto 15
StackMap locals:
StackMap stack: org.eclipse.jetty.util.thread.QueuedThreadPool
14: iconst_0
StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool java.lang.Runnable int
StackMap stack: org.eclipse.jetty.util.thread.QueuedThreadPool int
15: iconst_1
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.addCounts:(II)Z
ifeq 17
16: getstatic org.eclipse.jetty.util.thread.QueuedThreadPool.LOG:Lorg/eclipse/jetty/util/log/Logger;
ldc "{} rejected {}"
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
invokeinterface org.eclipse.jetty.util.log.Logger.warn:(Ljava/lang/String;[Ljava/lang/Object;)V
17: StackMap locals:
StackMap stack:
new java.util.concurrent.RejectedExecutionException
dup
aload 1
invokevirtual java.lang.Object.toString:()Ljava/lang/String;
invokespecial java.util.concurrent.RejectedExecutionException.<init>:(Ljava/lang/String;)V
athrow
18: StackMap locals:
StackMap stack:
getstatic org.eclipse.jetty.util.thread.QueuedThreadPool.LOG:Lorg/eclipse/jetty/util/log/Logger;
invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
ifeq 20
19: getstatic org.eclipse.jetty.util.thread.QueuedThreadPool.LOG:Lorg/eclipse/jetty/util/log/Logger;
ldc "queue {} startThread={}"
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 1
aastore
dup
iconst_1
iload 2
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
aastore
invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
20: StackMap locals:
StackMap stack:
iload 2
ifeq 22
21: aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.startThread:()V
22: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 23 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
0 23 1 job Ljava/lang/Runnable;
8 11 2 startThread Z
12 23 2 startThread Z
1 11 3 counts J
2 11 5 threads I
5 11 6 idle I
MethodParameters:
Name Flags
job
public boolean tryExecute(java.lang.Runnable);
descriptor: (Ljava/lang/Runnable;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._tryExecutor:Lorg/eclipse/jetty/util/thread/TryExecutor;
astore 2
start local 2 1: aload 2
ifnull 2
aload 2
aload 1
invokeinterface org.eclipse.jetty.util.thread.TryExecutor.tryExecute:(Ljava/lang/Runnable;)Z
ifeq 2
iconst_1
ireturn
StackMap locals: org.eclipse.jetty.util.thread.TryExecutor
StackMap stack:
2: iconst_0
ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
0 3 1 task Ljava/lang/Runnable;
1 3 2 tryExecutor Lorg/eclipse/jetty/util/thread/TryExecutor;
MethodParameters:
Name Flags
task
public void join();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._joinLock:Ljava/lang/Object;
dup
astore 1
monitorenter
1: goto 3
2: StackMap locals: java.lang.Object
StackMap stack:
aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._joinLock:Ljava/lang/Object;
invokevirtual java.lang.Object.wait:()V
3: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.isRunning:()Z
ifne 2
4: aload 1
monitorexit
5: goto 9
StackMap locals:
StackMap stack: java.lang.Throwable
6: aload 1
monitorexit
7: athrow
8: StackMap locals:
StackMap stack:
lconst_1
invokestatic java.lang.Thread.sleep:(J)V
9: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.isStopping:()Z
ifne 8
10: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
Exception table:
from to target type
1 5 6 any
6 7 6 any
Exceptions:
throws java.lang.InterruptedException
public int getThreads();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._counts:Lorg/eclipse/jetty/util/AtomicBiInteger;
invokevirtual org.eclipse.jetty.util.AtomicBiInteger.getHi:()I
istore 1
start local 1 1: iconst_0
iload 1
invokestatic java.lang.Math.max:(II)I
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
1 2 1 threads I
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedAttribute(value = "number of threads in the pool")
public int getIdleThreads();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._counts:Lorg/eclipse/jetty/util/AtomicBiInteger;
invokevirtual org.eclipse.jetty.util.AtomicBiInteger.getLo:()I
istore 1
start local 1 1: iconst_0
iload 1
invokestatic java.lang.Math.max:(II)I
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
1 2 1 idle I
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedAttribute(value = "number of idle threads in the pool")
public int getBusyThreads();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._tryExecutor:Lorg/eclipse/jetty/util/thread/TryExecutor;
instanceof org.eclipse.jetty.util.thread.ReservedThreadExecutor
ifeq 1
aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._tryExecutor:Lorg/eclipse/jetty/util/thread/TryExecutor;
checkcast org.eclipse.jetty.util.thread.ReservedThreadExecutor
invokevirtual org.eclipse.jetty.util.thread.ReservedThreadExecutor.getAvailable:()I
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: istore 1
start local 1 3: aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.getThreads:()I
aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.getIdleThreads:()I
isub
iload 1
isub
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
3 4 1 reserved I
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedAttribute(value = "number of busy threads in the pool")
public boolean isLowOnThreads();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.getMaxThreads:()I
aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.getThreads:()I
isub
aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.getIdleThreads:()I
iadd
aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.getQueueSize:()I
isub
aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.getLowThreadsThreshold:()I
if_icmpgt 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedAttribute(value = "thread pool is low on threads", readonly = true)
private void ensureThreads();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=5, args_size=1
start local 0 0: StackMap locals:
StackMap stack:
aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._counts:Lorg/eclipse/jetty/util/AtomicBiInteger;
invokevirtual org.eclipse.jetty.util.AtomicBiInteger.get:()J
lstore 1
start local 1 1: lload 1
invokestatic org.eclipse.jetty.util.AtomicBiInteger.getHi:(J)I
istore 3
start local 3 2: iload 3
ldc -2147483648
if_icmpne 4
3: goto 9
4: StackMap locals: long int
StackMap stack:
lload 1
invokestatic org.eclipse.jetty.util.AtomicBiInteger.getLo:(J)I
istore 4
start local 4 5: iload 3
aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._minThreads:I
if_icmplt 6
iload 4
ifge 9
iload 3
aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._maxThreads:I
if_icmpge 9
6: StackMap locals: int
StackMap stack:
aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._counts:Lorg/eclipse/jetty/util/AtomicBiInteger;
lload 1
iload 3
iconst_1
iadd
iload 4
invokevirtual org.eclipse.jetty.util.AtomicBiInteger.compareAndSet:(JII)Z
ifeq 0
7: aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.startThread:()V
end local 4 end local 3 end local 1 8: goto 0
9: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
1 8 1 counts J
2 8 3 threads I
5 8 4 idle I
protected void startThread();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=6, locals=4, args_size=1
start local 0 0: iconst_0
istore 1
start local 1 1: aload 0
aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._runnable:Ljava/lang/Runnable;
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.newThread:(Ljava/lang/Runnable;)Ljava/lang/Thread;
astore 2
start local 2 2: aload 2
aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.isDaemon:()Z
invokevirtual java.lang.Thread.setDaemon:(Z)V
3: aload 2
aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.getThreadsPriority:()I
invokevirtual java.lang.Thread.setPriority:(I)V
4: aload 2
new java.lang.StringBuilder
dup
aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._name:Ljava/lang/String;
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc "-"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 2
invokevirtual java.lang.Thread.getId:()J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.lang.Thread.setName:(Ljava/lang/String;)V
5: getstatic org.eclipse.jetty.util.thread.QueuedThreadPool.LOG:Lorg/eclipse/jetty/util/log/Logger;
invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
ifeq 7
6: getstatic org.eclipse.jetty.util.thread.QueuedThreadPool.LOG:Lorg/eclipse/jetty/util/log/Logger;
ldc "Starting {}"
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 2
aastore
invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
7: StackMap locals: int java.lang.Thread
StackMap stack:
aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._threads:Ljava/util/Set;
aload 2
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
8: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._lastShrink:Ljava/util/concurrent/atomic/AtomicLong;
invokestatic java.lang.System.nanoTime:()J
invokevirtual java.util.concurrent.atomic.AtomicLong.set:(J)V
9: aload 2
invokevirtual java.lang.Thread.start:()V
10: iconst_1
istore 1
end local 2 11: goto 16
12: StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool int
StackMap stack: java.lang.Throwable
astore 3
13: iload 1
ifne 15
14: aload 0
iconst_m1
iconst_0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.addCounts:(II)Z
pop
15: StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool int top java.lang.Throwable
StackMap stack:
aload 3
athrow
16: StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool int
StackMap stack:
iload 1
ifne 18
17: aload 0
iconst_m1
iconst_0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.addCounts:(II)Z
pop
18: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
1 19 1 started Z
2 11 2 thread Ljava/lang/Thread;
Exception table:
from to target type
1 12 12 any
private boolean addCounts(int, int);
descriptor: (II)Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=9, args_size=3
start local 0 start local 1 start local 2 0: StackMap locals:
StackMap stack:
aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._counts:Lorg/eclipse/jetty/util/AtomicBiInteger;
invokevirtual org.eclipse.jetty.util.AtomicBiInteger.get:()J
lstore 3
start local 3 1: lload 3
invokestatic org.eclipse.jetty.util.AtomicBiInteger.getHi:(J)I
istore 5
start local 5 2: lload 3
invokestatic org.eclipse.jetty.util.AtomicBiInteger.getLo:(J)I
istore 6
start local 6 3: iload 5
ldc -2147483648
if_icmpne 5
4: iconst_0
ireturn
5: StackMap locals: long int int
StackMap stack:
iload 5
iload 1
iadd
iload 6
iload 2
iadd
invokestatic org.eclipse.jetty.util.AtomicBiInteger.encode:(II)J
lstore 7
start local 7 6: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._counts:Lorg/eclipse/jetty/util/AtomicBiInteger;
lload 3
lload 7
invokevirtual org.eclipse.jetty.util.AtomicBiInteger.compareAndSet:(JJ)Z
ifeq 0
7: iconst_1
ireturn
end local 7 end local 6 end local 5 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
0 8 1 deltaThreads I
0 8 2 deltaIdle I
1 8 3 encoded J
2 8 5 threads I
3 8 6 idle I
6 8 7 update J
MethodParameters:
Name Flags
deltaThreads
deltaIdle
protected java.lang.Thread newThread(java.lang.Runnable);
descriptor: (Ljava/lang/Runnable;)Ljava/lang/Thread;
flags: (0x0004) ACC_PROTECTED
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: new java.lang.Thread
dup
aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._threadGroup:Ljava/lang/ThreadGroup;
aload 1
invokespecial java.lang.Thread.<init>:(Ljava/lang/ThreadGroup;Ljava/lang/Runnable;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
0 1 1 runnable Ljava/lang/Runnable;
MethodParameters:
Name Flags
runnable
protected void removeThread(java.lang.Thread);
descriptor: (Ljava/lang/Thread;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._threads:Ljava/util/Set;
aload 1
invokeinterface java.util.Set.remove:(Ljava/lang/Object;)Z
pop
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
0 2 1 thread Ljava/lang/Thread;
MethodParameters:
Name Flags
thread
public void dump(java.lang.Appendable, java.lang.String);
descriptor: (Ljava/lang/Appendable;Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=10, locals=12, args_size=3
start local 0 start local 1 start local 2 0: new java.util.ArrayList
dup
aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.getMaxThreads:()I
invokespecial java.util.ArrayList.<init>:(I)V
astore 3
start local 3 1: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._threads:Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 5
goto 31
StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool java.lang.Appendable java.lang.String java.util.List top java.util.Iterator
StackMap stack:
2: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.lang.Thread
astore 4
start local 4 3: aload 4
invokevirtual java.lang.Thread.getStackTrace:()[Ljava/lang/StackTraceElement;
astore 6
start local 6 4: ldc ""
astore 7
start local 7 5: aload 6
dup
astore 11
arraylength
istore 10
iconst_0
istore 9
goto 20
StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool java.lang.Appendable java.lang.String java.util.List java.lang.Thread java.util.Iterator java.lang.StackTraceElement[] java.lang.String top int int java.lang.StackTraceElement[]
StackMap stack:
6: aload 11
iload 9
aaload
astore 8
start local 8 7: ldc "idleJobPoll"
aload 8
invokevirtual java.lang.StackTraceElement.getMethodName:()Ljava/lang/String;
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 10
aload 8
invokevirtual java.lang.StackTraceElement.getClassName:()Ljava/lang/String;
ldc Lorg/eclipse/jetty/util/thread/QueuedThreadPool$Runner;
invokevirtual java.lang.Class.getName:()Ljava/lang/String;
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 10
8: ldc "IDLE "
astore 7
9: goto 21
10: StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool java.lang.Appendable java.lang.String java.util.List java.lang.Thread java.util.Iterator java.lang.StackTraceElement[] java.lang.String java.lang.StackTraceElement int int java.lang.StackTraceElement[]
StackMap stack:
ldc "reservedWait"
aload 8
invokevirtual java.lang.StackTraceElement.getMethodName:()Ljava/lang/String;
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 13
aload 8
invokevirtual java.lang.StackTraceElement.getClassName:()Ljava/lang/String;
ldc "ReservedThread"
invokevirtual java.lang.String.endsWith:(Ljava/lang/String;)Z
ifeq 13
11: ldc "RESERVED "
astore 7
12: goto 21
13: StackMap locals:
StackMap stack:
ldc "select"
aload 8
invokevirtual java.lang.StackTraceElement.getMethodName:()Ljava/lang/String;
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 16
aload 8
invokevirtual java.lang.StackTraceElement.getClassName:()Ljava/lang/String;
ldc "SelectorProducer"
invokevirtual java.lang.String.endsWith:(Ljava/lang/String;)Z
ifeq 16
14: ldc "SELECTING "
astore 7
15: goto 21
16: StackMap locals:
StackMap stack:
ldc "accept"
aload 8
invokevirtual java.lang.StackTraceElement.getMethodName:()Ljava/lang/String;
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 19
aload 8
invokevirtual java.lang.StackTraceElement.getClassName:()Ljava/lang/String;
ldc "ServerConnector"
invokevirtual java.lang.String.contains:(Ljava/lang/CharSequence;)Z
ifeq 19
17: ldc "ACCEPTING "
astore 7
18: goto 21
end local 8 19: StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool java.lang.Appendable java.lang.String java.util.List java.lang.Thread java.util.Iterator java.lang.StackTraceElement[] java.lang.String top int int java.lang.StackTraceElement[]
StackMap stack:
iinc 9 1
StackMap locals:
StackMap stack:
20: iload 9
iload 10
if_icmplt 6
21: StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool java.lang.Appendable java.lang.String java.util.List java.lang.Thread java.util.Iterator java.lang.StackTraceElement[] java.lang.String
StackMap stack:
aload 7
astore 8
start local 8 22: aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.isDetailedDump:()Z
ifeq 25
23: aload 3
new org.eclipse.jetty.util.thread.QueuedThreadPool$1
dup
aload 0
aload 8
aload 4
aload 6
invokespecial org.eclipse.jetty.util.thread.QueuedThreadPool$1.<init>:(Lorg/eclipse/jetty/util/thread/QueuedThreadPool;Ljava/lang/String;Ljava/lang/Thread;[Ljava/lang/StackTraceElement;)V
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
24: goto 31
25: StackMap locals: java.lang.String
StackMap stack:
aload 4
invokevirtual java.lang.Thread.getPriority:()I
istore 9
start local 9 26: aload 3
new java.lang.StringBuilder
dup
aload 4
invokevirtual java.lang.Thread.getId:()J
invokestatic java.lang.String.valueOf:(J)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc " "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 4
invokevirtual java.lang.Thread.getName:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc " "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 8
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 4
invokevirtual java.lang.Thread.getState:()Ljava/lang/Thread$State;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
ldc " @ "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 6
arraylength
ifle 27
aload 6
iconst_0
aaload
goto 28
StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool java.lang.Appendable java.lang.String java.util.List java.lang.Thread java.util.Iterator java.lang.StackTraceElement[] java.lang.String java.lang.String int
StackMap stack: java.util.List java.lang.StringBuilder
27: ldc "???"
StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool java.lang.Appendable java.lang.String java.util.List java.lang.Thread java.util.Iterator java.lang.StackTraceElement[] java.lang.String java.lang.String int
StackMap stack: java.util.List java.lang.StringBuilder java.io.Serializable
28: invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
iload 9
iconst_5
if_icmpne 29
ldc ""
goto 30
StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool java.lang.Appendable java.lang.String java.util.List java.lang.Thread java.util.Iterator java.lang.StackTraceElement[] java.lang.String java.lang.String int
StackMap stack: java.util.List java.lang.StringBuilder
29: new java.lang.StringBuilder
dup
ldc " prio="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
iload 9
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool java.lang.Appendable java.lang.String java.util.List java.lang.Thread java.util.Iterator java.lang.StackTraceElement[] java.lang.String java.lang.String int
StackMap stack: java.util.List java.lang.StringBuilder java.lang.String
30: invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 9 end local 8 end local 7 end local 6 end local 4 31: StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool java.lang.Appendable java.lang.String java.util.List top java.util.Iterator
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
32: aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.isDetailedDump:()Z
ifeq 36
33: new java.util.ArrayList
dup
aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.getQueue:()Ljava/util/concurrent/BlockingQueue;
invokespecial java.util.ArrayList.<init>:(Ljava/util/Collection;)V
astore 4
start local 4 34: aload 0
aload 1
aload 2
iconst_2
anewarray java.lang.Object
dup
iconst_0
new org.eclipse.jetty.util.component.DumpableCollection
dup
ldc "threads"
aload 3
invokespecial org.eclipse.jetty.util.component.DumpableCollection.<init>:(Ljava/lang/String;Ljava/util/Collection;)V
aastore
dup
iconst_1
new org.eclipse.jetty.util.component.DumpableCollection
dup
ldc "jobs"
aload 4
invokespecial org.eclipse.jetty.util.component.DumpableCollection.<init>:(Ljava/lang/String;Ljava/util/Collection;)V
aastore
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.dumpObjects:(Ljava/lang/Appendable;Ljava/lang/String;[Ljava/lang/Object;)V
end local 4 35: goto 37
36: StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool java.lang.Appendable java.lang.String java.util.List
StackMap stack:
aload 0
aload 1
aload 2
iconst_1
anewarray java.lang.Object
dup
iconst_0
new org.eclipse.jetty.util.component.DumpableCollection
dup
ldc "threads"
aload 3
invokespecial org.eclipse.jetty.util.component.DumpableCollection.<init>:(Ljava/lang/String;Ljava/util/Collection;)V
aastore
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.dumpObjects:(Ljava/lang/Appendable;Ljava/lang/String;[Ljava/lang/Object;)V
37: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 38 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
0 38 1 out Ljava/lang/Appendable;
0 38 2 indent Ljava/lang/String;
1 38 3 threads Ljava/util/List<Ljava/lang/Object;>;
3 31 4 thread Ljava/lang/Thread;
4 31 6 trace [Ljava/lang/StackTraceElement;
5 31 7 knownMethod Ljava/lang/String;
7 19 8 t Ljava/lang/StackTraceElement;
22 31 8 known Ljava/lang/String;
26 31 9 p I
34 35 4 jobs Ljava/util/List<Ljava/lang/Runnable;>;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
out
indent
public java.lang.String toString();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=6, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._counts:Lorg/eclipse/jetty/util/AtomicBiInteger;
invokevirtual org.eclipse.jetty.util.AtomicBiInteger.get:()J
lstore 1
start local 1 1: iconst_0
lload 1
invokestatic org.eclipse.jetty.util.AtomicBiInteger.getHi:(J)I
invokestatic java.lang.Math.max:(II)I
istore 3
start local 3 2: iconst_0
lload 1
invokestatic org.eclipse.jetty.util.AtomicBiInteger.getLo:(J)I
invokestatic java.lang.Math.max:(II)I
istore 4
start local 4 3: aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.getQueueSize:()I
istore 5
start local 5 4: ldc "%s[%s]@%x{%s,%d<=%d<=%d,i=%d,r=%d,q=%d}[%s]"
bipush 11
anewarray java.lang.Object
dup
iconst_0
5: aload 0
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokevirtual java.lang.Class.getSimpleName:()Ljava/lang/String;
aastore
dup
iconst_1
6: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._name:Ljava/lang/String;
aastore
dup
iconst_2
7: aload 0
invokevirtual java.lang.Object.hashCode:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_3
8: aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.getState:()Ljava/lang/String;
aastore
dup
iconst_4
9: aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.getMinThreads:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_5
10: iload 3
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
bipush 6
11: aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.getMaxThreads:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
bipush 7
12: iload 4
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
bipush 8
13: aload 0
invokevirtual org.eclipse.jetty.util.thread.QueuedThreadPool.getReservedThreads:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
bipush 9
14: iload 5
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
bipush 10
15: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._tryExecutor:Lorg/eclipse/jetty/util/thread/TryExecutor;
aastore
16: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
areturn
end local 5 end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 17 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
1 17 1 count J
2 17 3 threads I
3 17 4 idle I
4 17 5 queue I
protected void runJob(java.lang.Runnable);
descriptor: (Ljava/lang/Runnable;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 1
invokeinterface java.lang.Runnable.run:()V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
0 2 1 job Ljava/lang/Runnable;
MethodParameters:
Name Flags
job
protected java.util.concurrent.BlockingQueue<java.lang.Runnable> getQueue();
descriptor: ()Ljava/util/concurrent/BlockingQueue;
flags: (0x0004) ACC_PROTECTED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._jobs:Ljava/util/concurrent/BlockingQueue;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
Signature: ()Ljava/util/concurrent/BlockingQueue<Ljava/lang/Runnable;>;
public boolean interruptThread(long);
descriptor: (J)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=5, args_size=2
start local 0 start local 1 0: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._threads:Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 4
goto 5
StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool long top java.util.Iterator
StackMap stack:
1: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.lang.Thread
astore 3
start local 3 2: aload 3
invokevirtual java.lang.Thread.getId:()J
lload 1
lcmp
ifne 5
3: aload 3
invokevirtual java.lang.Thread.interrupt:()V
4: iconst_1
ireturn
end local 3 5: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
6: iconst_0
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
0 7 1 id J
2 5 3 thread Ljava/lang/Thread;
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedOperation(value = "interrupts a pool thread")
RuntimeVisibleParameterAnnotations:
0:
org.eclipse.jetty.util.annotation.Name(value = "id")
MethodParameters:
Name Flags
id
public java.lang.String dumpThread(long);
descriptor: (J)Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=10, args_size=2
start local 0 start local 1 0: aload 0
getfield org.eclipse.jetty.util.thread.QueuedThreadPool._threads:Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 4
goto 12
StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool long top java.util.Iterator
StackMap stack:
1: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.lang.Thread
astore 3
start local 3 2: aload 3
invokevirtual java.lang.Thread.getId:()J
lload 1
lcmp
ifne 12
3: new java.lang.StringBuilder
dup
invokespecial java.lang.StringBuilder.<init>:()V
astore 5
start local 5 4: aload 5
aload 3
invokevirtual java.lang.Thread.getId:()J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
ldc " "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 3
invokevirtual java.lang.Thread.getName:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc " "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
pop
5: aload 5
aload 3
invokevirtual java.lang.Thread.getState:()Ljava/lang/Thread$State;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
ldc ":"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokestatic java.lang.System.lineSeparator:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
pop
6: aload 3
invokevirtual java.lang.Thread.getStackTrace:()[Ljava/lang/StackTraceElement;
dup
astore 9
arraylength
istore 8
iconst_0
istore 7
goto 10
StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool long java.lang.Thread java.util.Iterator java.lang.StringBuilder top int int java.lang.StackTraceElement[]
StackMap stack:
7: aload 9
iload 7
aaload
astore 6
start local 6 8: aload 5
ldc " at "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 6
invokevirtual java.lang.StackTraceElement.toString:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokestatic java.lang.System.lineSeparator:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
pop
end local 6 9: iinc 7 1
StackMap locals:
StackMap stack:
10: iload 7
iload 8
if_icmplt 7
11: aload 5
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
areturn
end local 5 end local 3 12: StackMap locals: org.eclipse.jetty.util.thread.QueuedThreadPool long top java.util.Iterator
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
13: aconst_null
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lorg/eclipse/jetty/util/thread/QueuedThreadPool;
0 14 1 id J
2 12 3 thread Ljava/lang/Thread;
4 12 5 buf Ljava/lang/StringBuilder;
8 9 6 element Ljava/lang/StackTraceElement;
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedOperation(value = "dumps a pool thread stack")
RuntimeVisibleParameterAnnotations:
0:
org.eclipse.jetty.util.annotation.Name(value = "id")
MethodParameters:
Name Flags
id
private static void lambda$0();
descriptor: ()V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=0, locals=0, args_size=0
0: return
LocalVariableTable:
Start End Slot Name Signature
}
SourceFile: "QueuedThreadPool.java"
NestMembers:
org.eclipse.jetty.util.thread.QueuedThreadPool$1 org.eclipse.jetty.util.thread.QueuedThreadPool$Runner
InnerClasses:
public final State = java.lang.Thread$State of java.lang.Thread
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public KeySetView = java.util.concurrent.ConcurrentHashMap$KeySetView of java.util.concurrent.ConcurrentHashMap
org.eclipse.jetty.util.thread.QueuedThreadPool$1
private Runner = org.eclipse.jetty.util.thread.QueuedThreadPool$Runner of org.eclipse.jetty.util.thread.QueuedThreadPool
public abstract SizedThreadPool = org.eclipse.jetty.util.thread.ThreadPool$SizedThreadPool of org.eclipse.jetty.util.thread.ThreadPool
RuntimeVisibleAnnotations:
org.eclipse.jetty.util.annotation.ManagedObject(value = "A thread pool")