public class jdk.incubator.http.internal.common.Queue<T> implements jdk.incubator.http.internal.common.ExceptionallyCloseable
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: jdk.incubator.http.internal.common.Queue
super_class: java.lang.Object
{
private final java.util.LinkedList<T> q;
descriptor: Ljava/util/LinkedList;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/LinkedList<TT;>;
private volatile boolean closed;
descriptor: Z
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private volatile java.lang.Throwable exception;
descriptor: Ljava/lang/Throwable;
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private java.lang.Runnable callback;
descriptor: Ljava/lang/Runnable;
flags: (0x0002) ACC_PRIVATE
private boolean callbackDisabled;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private int waiters;
descriptor: I
flags: (0x0002) ACC_PRIVATE
public void <init>();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.LinkedList
dup
invokespecial java.util.LinkedList.<init>:()V
putfield jdk.incubator.http.internal.common.Queue.q:Ljava/util/LinkedList;
2: aload 0
iconst_0
putfield jdk.incubator.http.internal.common.Queue.closed:Z
3: aload 0
aconst_null
putfield jdk.incubator.http.internal.common.Queue.exception:Ljava/lang/Throwable;
4: aload 0
iconst_0
putfield jdk.incubator.http.internal.common.Queue.callbackDisabled:Z
5: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Ljdk/incubator/http/internal/common/Queue<TT;>;
public synchronized int size();
descriptor: ()I
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield jdk.incubator.http.internal.common.Queue.q:Ljava/util/LinkedList;
invokevirtual java.util.LinkedList.size:()I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Ljdk/incubator/http/internal/common/Queue<TT;>;
public synchronized boolean tryPut();
descriptor: (Ljava/lang/Object;)Z
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield jdk.incubator.http.internal.common.Queue.closed:Z
ifeq 1
iconst_0
ireturn
1: StackMap locals:
StackMap stack:
aload 0
aload 1
invokevirtual jdk.incubator.http.internal.common.Queue.put:(Ljava/lang/Object;)V
2: iconst_1
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Ljdk/incubator/http/internal/common/Queue<TT;>;
0 3 1 obj TT;
Exceptions:
throws java.io.IOException
Signature: (TT;)Z
MethodParameters:
Name Flags
obj
public synchronized void put();
descriptor: (Ljava/lang/Object;)V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield jdk.incubator.http.internal.common.Queue.closed:Z
ifeq 2
1: new java.io.IOException
dup
ldc "stream closed"
invokespecial java.io.IOException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aload 0
getfield jdk.incubator.http.internal.common.Queue.q:Ljava/util/LinkedList;
aload 1
invokevirtual java.util.LinkedList.add:(Ljava/lang/Object;)Z
pop
3: aload 0
getfield jdk.incubator.http.internal.common.Queue.waiters:I
ifle 5
4: aload 0
invokevirtual java.lang.Object.notifyAll:()V
5: StackMap locals:
StackMap stack:
aload 0
getfield jdk.incubator.http.internal.common.Queue.callbackDisabled:Z
ifeq 7
6: return
7: StackMap locals:
StackMap stack:
aload 0
getfield jdk.incubator.http.internal.common.Queue.q:Ljava/util/LinkedList;
invokevirtual java.util.LinkedList.size:()I
ifle 9
aload 0
getfield jdk.incubator.http.internal.common.Queue.callback:Ljava/lang/Runnable;
ifnull 9
8: aload 0
getfield jdk.incubator.http.internal.common.Queue.callback:Ljava/lang/Runnable;
invokeinterface java.lang.Runnable.run:()V
9: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Ljdk/incubator/http/internal/common/Queue<TT;>;
0 10 1 obj TT;
Exceptions:
throws java.io.IOException
Signature: (TT;)V
MethodParameters:
Name Flags
obj
public synchronized void disableCallback();
descriptor: ()V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
iconst_1
putfield jdk.incubator.http.internal.common.Queue.callbackDisabled:Z
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Ljdk/incubator/http/internal/common/Queue<TT;>;
public synchronized void enableCallback();
descriptor: ()V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
iconst_0
putfield jdk.incubator.http.internal.common.Queue.callbackDisabled:Z
1: goto 3
2: StackMap locals:
StackMap stack:
aload 0
getfield jdk.incubator.http.internal.common.Queue.callback:Ljava/lang/Runnable;
invokeinterface java.lang.Runnable.run:()V
3: StackMap locals:
StackMap stack:
aload 0
getfield jdk.incubator.http.internal.common.Queue.q:Ljava/util/LinkedList;
invokevirtual java.util.LinkedList.size:()I
ifgt 2
4: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Ljdk/incubator/http/internal/common/Queue<TT;>;
public synchronized void registerPutCallback(java.lang.Runnable);
descriptor: (Ljava/lang/Runnable;)V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
1: aload 0
aload 1
putfield jdk.incubator.http.internal.common.Queue.callback:Ljava/lang/Runnable;
2: aload 0
getfield jdk.incubator.http.internal.common.Queue.q:Ljava/util/LinkedList;
invokevirtual java.util.LinkedList.size:()I
ifle 4
3: aload 1
invokeinterface java.lang.Runnable.run:()V
4: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Ljdk/incubator/http/internal/common/Queue<TT;>;
0 5 1 callback Ljava/lang/Runnable;
MethodParameters:
Name Flags
callback
public synchronized void close();
descriptor: ()V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
iconst_1
putfield jdk.incubator.http.internal.common.Queue.closed:Z
1: aload 0
invokevirtual java.lang.Object.notifyAll:()V
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Ljdk/incubator/http/internal/common/Queue<TT;>;
public synchronized void closeExceptionally(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield jdk.incubator.http.internal.common.Queue.exception:Ljava/lang/Throwable;
ifnonnull 1
aload 0
aload 1
putfield jdk.incubator.http.internal.common.Queue.exception:Ljava/lang/Throwable;
goto 7
1: StackMap locals:
StackMap stack:
aload 1
ifnull 7
aload 1
aload 0
getfield jdk.incubator.http.internal.common.Queue.exception:Ljava/lang/Throwable;
if_acmpeq 7
2: aload 0
getfield jdk.incubator.http.internal.common.Queue.exception:Ljava/lang/Throwable;
invokevirtual java.lang.Throwable.getSuppressed:()[Ljava/lang/Throwable;
invokestatic java.util.stream.Stream.of:([Ljava/lang/Object;)Ljava/util/stream/Stream;
3: aload 1
invokedynamic test(Ljava/lang/Throwable;)Ljava/util/function/Predicate;
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;)Z
jdk/incubator/http/internal/common/Queue.lambda$0(Ljava/lang/Throwable;Ljava/lang/Throwable;)Z (6)
(Ljava/lang/Throwable;)Z
invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
4: invokeinterface java.util.stream.Stream.findFirst:()Ljava/util/Optional;
5: invokevirtual java.util.Optional.isPresent:()Z
ifne 7
6: aload 0
getfield jdk.incubator.http.internal.common.Queue.exception:Ljava/lang/Throwable;
aload 1
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
7: StackMap locals:
StackMap stack:
aload 0
invokevirtual jdk.incubator.http.internal.common.Queue.close:()V
8: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Ljdk/incubator/http/internal/common/Queue<TT;>;
0 9 1 t Ljava/lang/Throwable;
MethodParameters:
Name Flags
t
public synchronized T take();
descriptor: ()Ljava/lang/Object;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=3, locals=2, args_size=1
start local 0 0: aload 0
getfield jdk.incubator.http.internal.common.Queue.closed:Z
ifeq 7
1: aload 0
ldc "stream closed"
invokevirtual jdk.incubator.http.internal.common.Queue.newIOException:(Ljava/lang/String;)Ljava/io/IOException;
athrow
2: StackMap locals:
StackMap stack:
aload 0
dup
getfield jdk.incubator.http.internal.common.Queue.waiters:I
iconst_1
iadd
putfield jdk.incubator.http.internal.common.Queue.waiters:I
3: aload 0
invokevirtual java.lang.Object.wait:()V
4: aload 0
getfield jdk.incubator.http.internal.common.Queue.closed:Z
ifeq 6
5: aload 0
ldc "Queue closed"
invokevirtual jdk.incubator.http.internal.common.Queue.newIOException:(Ljava/lang/String;)Ljava/io/IOException;
athrow
6: StackMap locals:
StackMap stack:
aload 0
dup
getfield jdk.incubator.http.internal.common.Queue.waiters:I
iconst_1
isub
putfield jdk.incubator.http.internal.common.Queue.waiters:I
7: StackMap locals:
StackMap stack:
aload 0
getfield jdk.incubator.http.internal.common.Queue.q:Ljava/util/LinkedList;
invokevirtual java.util.LinkedList.size:()I
ifeq 2
8: aload 0
getfield jdk.incubator.http.internal.common.Queue.q:Ljava/util/LinkedList;
invokevirtual java.util.LinkedList.removeFirst:()Ljava/lang/Object;
9: areturn
10: StackMap locals:
StackMap stack: java.lang.InterruptedException
astore 1
start local 1 11: new java.io.IOException
dup
aload 1
invokespecial java.io.IOException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Ljdk/incubator/http/internal/common/Queue<TT;>;
11 12 1 ex Ljava/lang/InterruptedException;
Exception table:
from to target type
2 9 10 Class java.lang.InterruptedException
Exceptions:
throws java.io.IOException
Signature: ()TT;
public synchronized T poll();
descriptor: ()Ljava/lang/Object;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield jdk.incubator.http.internal.common.Queue.closed:Z
ifeq 2
1: aload 0
ldc "stream closed"
invokevirtual jdk.incubator.http.internal.common.Queue.newIOException:(Ljava/lang/String;)Ljava/io/IOException;
athrow
2: StackMap locals:
StackMap stack:
aload 0
getfield jdk.incubator.http.internal.common.Queue.q:Ljava/util/LinkedList;
invokevirtual java.util.LinkedList.isEmpty:()Z
ifeq 4
3: aconst_null
areturn
4: StackMap locals:
StackMap stack:
aload 0
getfield jdk.incubator.http.internal.common.Queue.q:Ljava/util/LinkedList;
invokevirtual java.util.LinkedList.removeFirst:()Ljava/lang/Object;
astore 1
start local 1 5: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Ljdk/incubator/http/internal/common/Queue<TT;>;
5 6 1 res TT;
Exceptions:
throws java.io.IOException
Signature: ()TT;
public synchronized T[] pollAll();
descriptor: ([Ljava/lang/Object;)[Ljava/lang/Object;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield jdk.incubator.http.internal.common.Queue.q:Ljava/util/LinkedList;
aload 1
invokevirtual java.util.LinkedList.toArray:([Ljava/lang/Object;)[Ljava/lang/Object;
astore 2
start local 2 1: aload 0
getfield jdk.incubator.http.internal.common.Queue.q:Ljava/util/LinkedList;
invokevirtual java.util.LinkedList.clear:()V
2: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Ljdk/incubator/http/internal/common/Queue<TT;>;
0 3 1 type [Ljava/lang/Object;
1 3 2 ret [Ljava/lang/Object;
Exceptions:
throws java.io.IOException
Signature: ([TT;)[TT;
MethodParameters:
Name Flags
type
public synchronized void pushback();
descriptor: (Ljava/lang/Object;)V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield jdk.incubator.http.internal.common.Queue.q:Ljava/util/LinkedList;
aload 1
invokevirtual java.util.LinkedList.addFirst:(Ljava/lang/Object;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Ljdk/incubator/http/internal/common/Queue<TT;>;
0 2 1 v TT;
Signature: (TT;)V
MethodParameters:
Name Flags
v
public synchronized void pushbackAll();
descriptor: ([Ljava/lang/Object;)V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 1
arraylength
iconst_1
isub
istore 2
start local 2 1: goto 4
2: StackMap locals: int
StackMap stack:
aload 0
getfield jdk.incubator.http.internal.common.Queue.q:Ljava/util/LinkedList;
aload 1
iload 2
aaload
invokevirtual java.util.LinkedList.addFirst:(Ljava/lang/Object;)V
3: iinc 2 -1
StackMap locals:
StackMap stack:
4: iload 2
ifge 2
end local 2 5: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Ljdk/incubator/http/internal/common/Queue<TT;>;
0 6 1 v [Ljava/lang/Object;
1 5 2 i I
Signature: ([TT;)V
MethodParameters:
Name Flags
v
private java.io.IOException newIOException(java.lang.String);
descriptor: (Ljava/lang/String;)Ljava/io/IOException;
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield jdk.incubator.http.internal.common.Queue.exception:Ljava/lang/Throwable;
ifnonnull 2
1: new java.io.IOException
dup
aload 1
invokespecial java.io.IOException.<init>:(Ljava/lang/String;)V
areturn
2: StackMap locals:
StackMap stack:
new java.io.IOException
dup
aload 1
aload 0
getfield jdk.incubator.http.internal.common.Queue.exception:Ljava/lang/Throwable;
invokespecial java.io.IOException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Ljdk/incubator/http/internal/common/Queue<TT;>;
0 3 1 msg Ljava/lang/String;
MethodParameters:
Name Flags
msg
private static boolean lambda$0(java.lang.Throwable, java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;Ljava/lang/Throwable;)Z
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 1
aload 0
if_acmpne 1
iconst_1
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: ireturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 3 1 x Ljava/lang/Throwable;
}
Signature: <T:Ljava/lang/Object;>Ljava/lang/Object;Ljdk/incubator/http/internal/common/ExceptionallyCloseable;
SourceFile: "Queue.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles