public class java.util.concurrent.Exchanger<V>
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: java.util.concurrent.Exchanger
super_class: java.lang.Object
{
private static final int ASHIFT;
descriptor: I
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: 5
private static final int MMASK;
descriptor: I
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: 255
private static final int SEQ;
descriptor: I
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: 256
private static final int NCPU;
descriptor: I
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
static final int FULL;
descriptor: I
flags: (0x0018) ACC_STATIC, ACC_FINAL
private static final int SPINS;
descriptor: I
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: 1024
private static final java.lang.Object NULL_ITEM;
descriptor: Ljava/lang/Object;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final java.lang.Object TIMED_OUT;
descriptor: Ljava/lang/Object;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private final java.util.concurrent.Exchanger$Participant participant;
descriptor: Ljava/util/concurrent/Exchanger$Participant;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private volatile java.util.concurrent.Exchanger$Node[] arena;
descriptor: [Ljava/util/concurrent/Exchanger$Node;
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private volatile java.util.concurrent.Exchanger$Node slot;
descriptor: Ljava/util/concurrent/Exchanger$Node;
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private volatile int bound;
descriptor: I
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private static final java.lang.invoke.VarHandle BOUND;
descriptor: Ljava/lang/invoke/VarHandle;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final java.lang.invoke.VarHandle SLOT;
descriptor: Ljava/lang/invoke/VarHandle;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final java.lang.invoke.VarHandle MATCH;
descriptor: Ljava/lang/invoke/VarHandle;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final java.lang.invoke.VarHandle AA;
descriptor: Ljava/lang/invoke/VarHandle;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=4, locals=1, args_size=0
0: invokestatic java.lang.Runtime.getRuntime:()Ljava/lang/Runtime;
invokevirtual java.lang.Runtime.availableProcessors:()I
putstatic java.util.concurrent.Exchanger.NCPU:I
1: getstatic java.util.concurrent.Exchanger.NCPU:I
sipush 510
if_icmplt 2
sipush 255
goto 3
StackMap locals:
StackMap stack:
2: getstatic java.util.concurrent.Exchanger.NCPU:I
iconst_1
iushr
StackMap locals:
StackMap stack: int
3: putstatic java.util.concurrent.Exchanger.FULL:I
4: new java.lang.Object
dup
invokespecial java.lang.Object.<init>:()V
putstatic java.util.concurrent.Exchanger.NULL_ITEM:Ljava/lang/Object;
5: new java.lang.Object
dup
invokespecial java.lang.Object.<init>:()V
putstatic java.util.concurrent.Exchanger.TIMED_OUT:Ljava/lang/Object;
6: invokestatic java.lang.invoke.MethodHandles.lookup:()Ljava/lang/invoke/MethodHandles$Lookup;
astore 0
start local 0 7: aload 0
ldc Ljava/util/concurrent/Exchanger;
ldc "bound"
getstatic java.lang.Integer.TYPE:Ljava/lang/Class;
invokevirtual java.lang.invoke.MethodHandles$Lookup.findVarHandle:(Ljava/lang/Class;Ljava/lang/String;Ljava/lang/Class;)Ljava/lang/invoke/VarHandle;
putstatic java.util.concurrent.Exchanger.BOUND:Ljava/lang/invoke/VarHandle;
8: aload 0
ldc Ljava/util/concurrent/Exchanger;
ldc "slot"
ldc Ljava/util/concurrent/Exchanger$Node;
invokevirtual java.lang.invoke.MethodHandles$Lookup.findVarHandle:(Ljava/lang/Class;Ljava/lang/String;Ljava/lang/Class;)Ljava/lang/invoke/VarHandle;
putstatic java.util.concurrent.Exchanger.SLOT:Ljava/lang/invoke/VarHandle;
9: aload 0
ldc Ljava/util/concurrent/Exchanger$Node;
ldc "match"
ldc Ljava/lang/Object;
invokevirtual java.lang.invoke.MethodHandles$Lookup.findVarHandle:(Ljava/lang/Class;Ljava/lang/String;Ljava/lang/Class;)Ljava/lang/invoke/VarHandle;
putstatic java.util.concurrent.Exchanger.MATCH:Ljava/lang/invoke/VarHandle;
10: ldc [Ljava/util/concurrent/Exchanger$Node;
invokestatic java.lang.invoke.MethodHandles.arrayElementVarHandle:(Ljava/lang/Class;)Ljava/lang/invoke/VarHandle;
putstatic java.util.concurrent.Exchanger.AA:Ljava/lang/invoke/VarHandle;
end local 0 11: goto 14
StackMap locals:
StackMap stack: java.lang.ReflectiveOperationException
12: astore 0
start local 0 13: new java.lang.ExceptionInInitializerError
dup
aload 0
invokespecial java.lang.ExceptionInInitializerError.<init>:(Ljava/lang/Throwable;)V
athrow
end local 0 14: StackMap locals:
StackMap stack:
return
LocalVariableTable:
Start End Slot Name Signature
7 11 0 l Ljava/lang/invoke/MethodHandles$Lookup;
13 14 0 e Ljava/lang/ReflectiveOperationException;
Exception table:
from to target type
6 11 12 Class java.lang.ReflectiveOperationException
private final java.lang.Object arenaExchange(java.lang.Object, boolean, long);
descriptor: (Ljava/lang/Object;ZJ)Ljava/lang/Object;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Code:
stack=5, locals=20, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield java.util.concurrent.Exchanger.arena:[Ljava/util/concurrent/Exchanger$Node;
astore 5
start local 5 1: aload 5
arraylength
istore 6
start local 6 2: aload 0
getfield java.util.concurrent.Exchanger.participant:Ljava/util/concurrent/Exchanger$Participant;
invokevirtual java.util.concurrent.Exchanger$Participant.get:()Ljava/lang/Object;
checkcast java.util.concurrent.Exchanger$Node
astore 7
start local 7 3: aload 7
getfield java.util.concurrent.Exchanger$Node.index:I
istore 8
start local 8 4: StackMap locals: java.util.concurrent.Exchanger java.lang.Object int long java.util.concurrent.Exchanger$Node[] int java.util.concurrent.Exchanger$Node int
StackMap stack:
iload 8
iconst_5
ishl
bipush 31
iadd
istore 12
start local 12 5: iload 12
iflt 6
iload 12
iload 6
if_icmplt 7
6: StackMap locals: java.util.concurrent.Exchanger java.lang.Object int long java.util.concurrent.Exchanger$Node[] int java.util.concurrent.Exchanger$Node int top top top int
StackMap stack:
iload 6
iconst_1
isub
istore 12
7: StackMap locals:
StackMap stack:
getstatic java.util.concurrent.Exchanger.AA:Ljava/lang/invoke/VarHandle;
aload 5
iload 12
invokevirtual java.lang.invoke.VarHandle.getAcquire:([Ljava/util/concurrent/Exchanger$Node;I)Ljava/util/concurrent/Exchanger$Node;
astore 13
start local 13 8: aload 13
ifnull 15
getstatic java.util.concurrent.Exchanger.AA:Ljava/lang/invoke/VarHandle;
aload 5
iload 12
aload 13
aconst_null
invokevirtual java.lang.invoke.VarHandle.compareAndSet:([Ljava/util/concurrent/Exchanger$Node;ILjava/util/concurrent/Exchanger$Node;Ljava/lang/Void;)Z
ifeq 15
9: aload 13
getfield java.util.concurrent.Exchanger$Node.item:Ljava/lang/Object;
astore 14
start local 14 10: aload 13
aload 1
putfield java.util.concurrent.Exchanger$Node.match:Ljava/lang/Object;
11: aload 13
getfield java.util.concurrent.Exchanger$Node.parked:Ljava/lang/Thread;
astore 15
start local 15 12: aload 15
ifnull 14
13: aload 15
invokestatic java.util.concurrent.locks.LockSupport.unpark:(Ljava/lang/Thread;)V
14: StackMap locals: java.util.concurrent.Exchanger$Node java.lang.Object java.lang.Thread
StackMap stack:
aload 14
areturn
end local 15 end local 14 15: StackMap locals:
StackMap stack:
iload 8
aload 0
getfield java.util.concurrent.Exchanger.bound:I
dup
istore 9
start local 9 16: sipush 255
iand
dup
istore 10
start local 10 17: if_icmpgt 65
aload 13
ifnonnull 65
18: aload 7
aload 1
putfield java.util.concurrent.Exchanger$Node.item:Ljava/lang/Object;
19: getstatic java.util.concurrent.Exchanger.AA:Ljava/lang/invoke/VarHandle;
aload 5
iload 12
aconst_null
aload 7
invokevirtual java.lang.invoke.VarHandle.compareAndSet:([Ljava/util/concurrent/Exchanger$Node;ILjava/lang/Void;Ljava/util/concurrent/Exchanger$Node;)Z
ifeq 63
20: iload 2
ifeq 21
iload 10
ifne 21
invokestatic java.lang.System.nanoTime:()J
lload 3
ladd
goto 22
StackMap locals: java.util.concurrent.Exchanger java.lang.Object int long java.util.concurrent.Exchanger$Node[] int java.util.concurrent.Exchanger$Node int int int top int java.util.concurrent.Exchanger$Node
StackMap stack:
21: lconst_0
StackMap locals:
StackMap stack: long
22: lstore 14
start local 14 23: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
astore 16
start local 16 24: aload 7
getfield java.util.concurrent.Exchanger$Node.hash:I
istore 17
start local 17 25: sipush 1024
istore 18
start local 18 26: StackMap locals: java.util.concurrent.Exchanger java.lang.Object int long java.util.concurrent.Exchanger$Node[] int java.util.concurrent.Exchanger$Node int int int top int java.util.concurrent.Exchanger$Node long java.lang.Thread int int
StackMap stack:
aload 7
getfield java.util.concurrent.Exchanger$Node.match:Ljava/lang/Object;
astore 19
start local 19 27: aload 19
ifnull 32
28: getstatic java.util.concurrent.Exchanger.MATCH:Ljava/lang/invoke/VarHandle;
aload 7
aconst_null
invokevirtual java.lang.invoke.VarHandle.setRelease:(Ljava/util/concurrent/Exchanger$Node;Ljava/lang/Void;)V
29: aload 7
aconst_null
putfield java.util.concurrent.Exchanger$Node.item:Ljava/lang/Object;
30: aload 7
iload 17
putfield java.util.concurrent.Exchanger$Node.hash:I
31: aload 19
areturn
32: StackMap locals: java.lang.Object
StackMap stack:
iload 18
ifle 40
33: iload 17
iload 17
iconst_1
ishl
ixor
istore 17
iload 17
iload 17
iconst_3
iushr
ixor
istore 17
iload 17
iload 17
bipush 10
ishl
ixor
istore 17
34: iload 17
ifne 36
35: sipush 1024
aload 16
invokevirtual java.lang.Thread.getId:()J
l2i
ior
istore 17
goto 26
36: StackMap locals:
StackMap stack:
iload 17
ifge 26
37: iinc 18 -1
iload 18
sipush 511
iand
ifne 26
38: invokestatic java.lang.Thread.yield:()V
39: goto 26
40: StackMap locals:
StackMap stack:
getstatic java.util.concurrent.Exchanger.AA:Ljava/lang/invoke/VarHandle;
aload 5
iload 12
invokevirtual java.lang.invoke.VarHandle.getAcquire:([Ljava/util/concurrent/Exchanger$Node;I)Ljava/lang/Object;
aload 7
if_acmpeq 42
41: sipush 1024
istore 18
goto 26
42: StackMap locals:
StackMap stack:
aload 16
invokevirtual java.lang.Thread.isInterrupted:()Z
ifne 52
iload 10
ifne 52
43: iload 2
ifeq 45
44: lload 14
invokestatic java.lang.System.nanoTime:()J
lsub
dup2
lstore 3
lconst_0
lcmp
ifle 52
45: StackMap locals:
StackMap stack:
aload 7
aload 16
putfield java.util.concurrent.Exchanger$Node.parked:Ljava/lang/Thread;
46: getstatic java.util.concurrent.Exchanger.AA:Ljava/lang/invoke/VarHandle;
aload 5
iload 12
invokevirtual java.lang.invoke.VarHandle.getAcquire:([Ljava/util/concurrent/Exchanger$Node;I)Ljava/lang/Object;
aload 7
if_acmpne 50
47: lload 3
lconst_0
lcmp
ifne 49
48: aload 0
invokestatic java.util.concurrent.locks.LockSupport.park:(Ljava/lang/Object;)V
goto 50
49: StackMap locals:
StackMap stack:
aload 0
lload 3
invokestatic java.util.concurrent.locks.LockSupport.parkNanos:(Ljava/lang/Object;J)V
50: StackMap locals:
StackMap stack:
aload 7
aconst_null
putfield java.util.concurrent.Exchanger$Node.parked:Ljava/lang/Thread;
51: goto 26
52: StackMap locals:
StackMap stack:
getstatic java.util.concurrent.Exchanger.AA:Ljava/lang/invoke/VarHandle;
aload 5
iload 12
invokevirtual java.lang.invoke.VarHandle.getAcquire:([Ljava/util/concurrent/Exchanger$Node;I)Ljava/lang/Object;
aload 7
if_acmpne 26
53: getstatic java.util.concurrent.Exchanger.AA:Ljava/lang/invoke/VarHandle;
aload 5
iload 12
aload 7
aconst_null
invokevirtual java.lang.invoke.VarHandle.compareAndSet:([Ljava/util/concurrent/Exchanger$Node;ILjava/util/concurrent/Exchanger$Node;Ljava/lang/Void;)Z
ifeq 26
54: iload 10
ifeq 56
55: getstatic java.util.concurrent.Exchanger.BOUND:Ljava/lang/invoke/VarHandle;
aload 0
iload 9
iload 9
sipush 256
iadd
iconst_1
isub
invokevirtual java.lang.invoke.VarHandle.compareAndSet:(Ljava/util/concurrent/Exchanger;II)V
56: StackMap locals:
StackMap stack:
aload 7
aconst_null
putfield java.util.concurrent.Exchanger$Node.item:Ljava/lang/Object;
57: aload 7
iload 17
putfield java.util.concurrent.Exchanger$Node.hash:I
58: aload 7
dup
getfield java.util.concurrent.Exchanger$Node.index:I
iconst_1
iushr
dup_x1
putfield java.util.concurrent.Exchanger$Node.index:I
istore 8
59: invokestatic java.lang.Thread.interrupted:()Z
ifeq 61
60: aconst_null
areturn
61: StackMap locals:
StackMap stack:
iload 2
ifeq 4
iload 10
ifne 4
lload 3
lconst_0
lcmp
ifgt 4
62: getstatic java.util.concurrent.Exchanger.TIMED_OUT:Ljava/lang/Object;
areturn
end local 19 end local 18 end local 17 end local 16 end local 14 63: StackMap locals: java.util.concurrent.Exchanger java.lang.Object int long java.util.concurrent.Exchanger$Node[] int java.util.concurrent.Exchanger$Node int int int top int java.util.concurrent.Exchanger$Node
StackMap stack:
aload 7
aconst_null
putfield java.util.concurrent.Exchanger$Node.item:Ljava/lang/Object;
64: goto 4
65: StackMap locals:
StackMap stack:
aload 7
getfield java.util.concurrent.Exchanger$Node.bound:I
iload 9
if_icmpeq 73
66: aload 7
iload 9
putfield java.util.concurrent.Exchanger$Node.bound:I
67: aload 7
iconst_0
putfield java.util.concurrent.Exchanger$Node.collides:I
68: iload 8
iload 10
if_icmpne 69
iload 10
ifne 70
StackMap locals:
StackMap stack:
69: iload 10
goto 71
StackMap locals:
StackMap stack:
70: iload 10
iconst_1
isub
StackMap locals:
StackMap stack: int
71: istore 8
72: goto 82
73: StackMap locals:
StackMap stack:
aload 7
getfield java.util.concurrent.Exchanger$Node.collides:I
dup
istore 11
start local 11 74: iload 10
if_icmplt 76
iload 10
getstatic java.util.concurrent.Exchanger.FULL:I
if_icmpeq 76
75: getstatic java.util.concurrent.Exchanger.BOUND:Ljava/lang/invoke/VarHandle;
aload 0
iload 9
iload 9
sipush 256
iadd
iconst_1
iadd
invokevirtual java.lang.invoke.VarHandle.compareAndSet:(Ljava/util/concurrent/Exchanger;II)Z
ifne 81
76: StackMap locals: java.util.concurrent.Exchanger java.lang.Object int long java.util.concurrent.Exchanger$Node[] int java.util.concurrent.Exchanger$Node int int int int int java.util.concurrent.Exchanger$Node
StackMap stack:
aload 7
iload 11
iconst_1
iadd
putfield java.util.concurrent.Exchanger$Node.collides:I
77: iload 8
ifne 78
iload 10
goto 79
StackMap locals:
StackMap stack:
78: iload 8
iconst_1
isub
StackMap locals:
StackMap stack: int
79: istore 8
80: goto 82
81: StackMap locals:
StackMap stack:
iload 10
iconst_1
iadd
istore 8
end local 11 82: StackMap locals: java.util.concurrent.Exchanger java.lang.Object int long java.util.concurrent.Exchanger$Node[] int java.util.concurrent.Exchanger$Node int int int top int java.util.concurrent.Exchanger$Node
StackMap stack:
aload 7
iload 8
putfield java.util.concurrent.Exchanger$Node.index:I
end local 13 end local 12 end local 10 end local 9 83: goto 4
end local 8 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 84 0 this Ljava/util/concurrent/Exchanger<TV;>;
0 84 1 item Ljava/lang/Object;
0 84 2 timed Z
0 84 3 ns J
1 84 5 a [Ljava/util/concurrent/Exchanger$Node;
2 84 6 alen I
3 84 7 p Ljava/util/concurrent/Exchanger$Node;
4 84 8 i I
16 83 9 b I
17 83 10 m I
74 82 11 c I
5 83 12 j I
8 83 13 q Ljava/util/concurrent/Exchanger$Node;
10 15 14 v Ljava/lang/Object;
12 15 15 w Ljava/lang/Thread;
23 63 14 end J
24 63 16 t Ljava/lang/Thread;
25 63 17 h I
26 63 18 spins I
27 63 19 v Ljava/lang/Object;
MethodParameters:
Name Flags
item
timed
ns
private final java.lang.Object slotExchange(java.lang.Object, boolean, long);
descriptor: (Ljava/lang/Object;ZJ)Ljava/lang/Object;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Code:
stack=4, locals=12, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield java.util.concurrent.Exchanger.participant:Ljava/util/concurrent/Exchanger$Participant;
invokevirtual java.util.concurrent.Exchanger$Participant.get:()Ljava/lang/Object;
checkcast java.util.concurrent.Exchanger$Node
astore 5
start local 5 1: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
astore 6
start local 6 2: aload 6
invokevirtual java.lang.Thread.isInterrupted:()Z
ifeq 4
3: aconst_null
areturn
4: StackMap locals: java.util.concurrent.Exchanger$Node java.lang.Thread
StackMap stack:
aload 0
getfield java.util.concurrent.Exchanger.slot:Ljava/util/concurrent/Exchanger$Node;
dup
astore 7
start local 7 5: ifnull 17
6: getstatic java.util.concurrent.Exchanger.SLOT:Ljava/lang/invoke/VarHandle;
aload 0
aload 7
aconst_null
invokevirtual java.lang.invoke.VarHandle.compareAndSet:(Ljava/util/concurrent/Exchanger;Ljava/util/concurrent/Exchanger$Node;Ljava/lang/Void;)Z
ifeq 13
7: aload 7
getfield java.util.concurrent.Exchanger$Node.item:Ljava/lang/Object;
astore 8
start local 8 8: aload 7
aload 1
putfield java.util.concurrent.Exchanger$Node.match:Ljava/lang/Object;
9: aload 7
getfield java.util.concurrent.Exchanger$Node.parked:Ljava/lang/Thread;
astore 9
start local 9 10: aload 9
ifnull 12
11: aload 9
invokestatic java.util.concurrent.locks.LockSupport.unpark:(Ljava/lang/Thread;)V
12: StackMap locals: java.util.concurrent.Exchanger$Node java.lang.Object java.lang.Thread
StackMap stack:
aload 8
areturn
end local 9 end local 8 13: StackMap locals:
StackMap stack:
getstatic java.util.concurrent.Exchanger.NCPU:I
iconst_1
if_icmple 4
aload 0
getfield java.util.concurrent.Exchanger.bound:I
ifne 4
14: getstatic java.util.concurrent.Exchanger.BOUND:Ljava/lang/invoke/VarHandle;
aload 0
iconst_0
sipush 256
invokevirtual java.lang.invoke.VarHandle.compareAndSet:(Ljava/util/concurrent/Exchanger;II)Z
ifeq 4
15: aload 0
getstatic java.util.concurrent.Exchanger.FULL:I
iconst_2
iadd
iconst_5
ishl
anewarray java.util.concurrent.Exchanger$Node
putfield java.util.concurrent.Exchanger.arena:[Ljava/util/concurrent/Exchanger$Node;
16: goto 4
17: StackMap locals:
StackMap stack:
aload 0
getfield java.util.concurrent.Exchanger.arena:[Ljava/util/concurrent/Exchanger$Node;
ifnull 19
18: aconst_null
areturn
19: StackMap locals:
StackMap stack:
aload 5
aload 1
putfield java.util.concurrent.Exchanger$Node.item:Ljava/lang/Object;
20: getstatic java.util.concurrent.Exchanger.SLOT:Ljava/lang/invoke/VarHandle;
aload 0
aconst_null
aload 5
invokevirtual java.lang.invoke.VarHandle.compareAndSet:(Ljava/util/concurrent/Exchanger;Ljava/lang/Void;Ljava/util/concurrent/Exchanger$Node;)Z
ifeq 22
21: goto 24
22: StackMap locals:
StackMap stack:
aload 5
aconst_null
putfield java.util.concurrent.Exchanger$Node.item:Ljava/lang/Object;
end local 7 23: goto 4
24: StackMap locals:
StackMap stack:
aload 5
getfield java.util.concurrent.Exchanger$Node.hash:I
istore 7
start local 7 25: iload 2
ifeq 26
invokestatic java.lang.System.nanoTime:()J
lload 3
ladd
goto 27
StackMap locals: int
StackMap stack:
26: lconst_0
StackMap locals:
StackMap stack: long
27: lstore 8
start local 8 28: getstatic java.util.concurrent.Exchanger.NCPU:I
iconst_1
if_icmple 29
sipush 1024
goto 30
StackMap locals: long
StackMap stack:
29: iconst_1
StackMap locals:
StackMap stack: int
30: istore 10
start local 10 31: goto 55
start local 11 32: StackMap locals: int java.lang.Object
StackMap stack:
iload 10
ifle 39
33: iload 7
iload 7
iconst_1
ishl
ixor
istore 7
iload 7
iload 7
iconst_3
iushr
ixor
istore 7
iload 7
iload 7
bipush 10
ishl
ixor
istore 7
34: iload 7
ifne 36
35: sipush 1024
aload 6
invokevirtual java.lang.Thread.getId:()J
l2i
ior
istore 7
goto 55
36: StackMap locals:
StackMap stack:
iload 7
ifge 55
iinc 10 -1
iload 10
sipush 511
iand
ifne 55
37: invokestatic java.lang.Thread.yield:()V
38: goto 55
39: StackMap locals:
StackMap stack:
aload 0
getfield java.util.concurrent.Exchanger.slot:Ljava/util/concurrent/Exchanger$Node;
aload 5
if_acmpeq 41
40: sipush 1024
istore 10
goto 55
41: StackMap locals:
StackMap stack:
aload 6
invokevirtual java.lang.Thread.isInterrupted:()Z
ifne 50
aload 0
getfield java.util.concurrent.Exchanger.arena:[Ljava/util/concurrent/Exchanger$Node;
ifnonnull 50
42: iload 2
ifeq 43
lload 8
invokestatic java.lang.System.nanoTime:()J
lsub
dup2
lstore 3
lconst_0
lcmp
ifle 50
43: StackMap locals:
StackMap stack:
aload 5
aload 6
putfield java.util.concurrent.Exchanger$Node.parked:Ljava/lang/Thread;
44: aload 0
getfield java.util.concurrent.Exchanger.slot:Ljava/util/concurrent/Exchanger$Node;
aload 5
if_acmpne 48
45: lload 3
lconst_0
lcmp
ifne 47
46: aload 0
invokestatic java.util.concurrent.locks.LockSupport.park:(Ljava/lang/Object;)V
goto 48
47: StackMap locals:
StackMap stack:
aload 0
lload 3
invokestatic java.util.concurrent.locks.LockSupport.parkNanos:(Ljava/lang/Object;J)V
48: StackMap locals:
StackMap stack:
aload 5
aconst_null
putfield java.util.concurrent.Exchanger$Node.parked:Ljava/lang/Thread;
49: goto 55
50: StackMap locals:
StackMap stack:
getstatic java.util.concurrent.Exchanger.SLOT:Ljava/lang/invoke/VarHandle;
aload 0
aload 5
aconst_null
invokevirtual java.lang.invoke.VarHandle.compareAndSet:(Ljava/util/concurrent/Exchanger;Ljava/util/concurrent/Exchanger$Node;Ljava/lang/Void;)Z
ifeq 55
51: iload 2
ifeq 52
lload 3
lconst_0
lcmp
ifgt 52
aload 6
invokevirtual java.lang.Thread.isInterrupted:()Z
ifne 52
getstatic java.util.concurrent.Exchanger.TIMED_OUT:Ljava/lang/Object;
goto 53
StackMap locals:
StackMap stack:
52: aconst_null
StackMap locals:
StackMap stack: java.lang.Object
53: astore 11
54: goto 57
end local 11 55: StackMap locals:
StackMap stack:
aload 5
getfield java.util.concurrent.Exchanger$Node.match:Ljava/lang/Object;
dup
astore 11
start local 11 56: ifnull 32
57: StackMap locals: java.lang.Object
StackMap stack:
getstatic java.util.concurrent.Exchanger.MATCH:Ljava/lang/invoke/VarHandle;
aload 5
aconst_null
invokevirtual java.lang.invoke.VarHandle.setRelease:(Ljava/util/concurrent/Exchanger$Node;Ljava/lang/Void;)V
58: aload 5
aconst_null
putfield java.util.concurrent.Exchanger$Node.item:Ljava/lang/Object;
59: aload 5
iload 7
putfield java.util.concurrent.Exchanger$Node.hash:I
60: aload 11
areturn
end local 11 end local 10 end local 8 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 61 0 this Ljava/util/concurrent/Exchanger<TV;>;
0 61 1 item Ljava/lang/Object;
0 61 2 timed Z
0 61 3 ns J
1 61 5 p Ljava/util/concurrent/Exchanger$Node;
2 61 6 t Ljava/lang/Thread;
5 23 7 q Ljava/util/concurrent/Exchanger$Node;
8 13 8 v Ljava/lang/Object;
10 13 9 w Ljava/lang/Thread;
25 61 7 h I
28 61 8 end J
31 61 10 spins I
32 55 11 v Ljava/lang/Object;
56 61 11 v Ljava/lang/Object;
MethodParameters:
Name Flags
item
timed
ns
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.concurrent.Exchanger$Participant
dup
invokespecial java.util.concurrent.Exchanger$Participant.<init>:()V
putfield java.util.concurrent.Exchanger.participant:Ljava/util/concurrent/Exchanger$Participant;
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Ljava/util/concurrent/Exchanger<TV;>;
public V exchange();
descriptor: (Ljava/lang/Object;)Ljava/lang/Object;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=2
start local 0 start local 1 0: aload 1
ifnonnull 1
getstatic java.util.concurrent.Exchanger.NULL_ITEM:Ljava/lang/Object;
goto 2
StackMap locals:
StackMap stack:
1: aload 1
StackMap locals:
StackMap stack: java.lang.Object
2: astore 3
start local 3 3: aload 0
getfield java.util.concurrent.Exchanger.arena:[Ljava/util/concurrent/Exchanger$Node;
ifnonnull 6
4: aload 0
aload 3
iconst_0
lconst_0
invokevirtual java.util.concurrent.Exchanger.slotExchange:(Ljava/lang/Object;ZJ)Ljava/lang/Object;
dup
astore 2
start local 2 5: ifnonnull 10
end local 2 6: StackMap locals: java.util.concurrent.Exchanger java.lang.Object top java.lang.Object
StackMap stack:
invokestatic java.lang.Thread.interrupted:()Z
ifne 9
7: aload 0
aload 3
iconst_0
lconst_0
invokevirtual java.util.concurrent.Exchanger.arenaExchange:(Ljava/lang/Object;ZJ)Ljava/lang/Object;
dup
astore 2
start local 2 8: ifnonnull 10
end local 2 9: StackMap locals:
StackMap stack:
new java.lang.InterruptedException
dup
invokespecial java.lang.InterruptedException.<init>:()V
athrow
start local 2 10: StackMap locals: java.util.concurrent.Exchanger java.lang.Object java.lang.Object java.lang.Object
StackMap stack:
aload 2
getstatic java.util.concurrent.Exchanger.NULL_ITEM:Ljava/lang/Object;
if_acmpne 11
aconst_null
goto 12
StackMap locals:
StackMap stack:
11: aload 2
StackMap locals:
StackMap stack: java.lang.Object
12: areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Ljava/util/concurrent/Exchanger<TV;>;
0 13 1 x TV;
5 6 2 v Ljava/lang/Object;
8 9 2 v Ljava/lang/Object;
10 13 2 v Ljava/lang/Object;
3 13 3 item Ljava/lang/Object;
Exceptions:
throws java.lang.InterruptedException
Signature: (TV;)TV;
MethodParameters:
Name Flags
x
public V exchange(V, long, java.util.concurrent.TimeUnit);
descriptor: (Ljava/lang/Object;JLjava/util/concurrent/TimeUnit;)Ljava/lang/Object;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=9, args_size=4
start local 0 start local 1 start local 2 start local 4 0: aload 1
ifnonnull 1
getstatic java.util.concurrent.Exchanger.NULL_ITEM:Ljava/lang/Object;
goto 2
StackMap locals:
StackMap stack:
1: aload 1
StackMap locals:
StackMap stack: java.lang.Object
2: astore 6
start local 6 3: aload 4
lload 2
invokevirtual java.util.concurrent.TimeUnit.toNanos:(J)J
lstore 7
start local 7 4: aload 0
getfield java.util.concurrent.Exchanger.arena:[Ljava/util/concurrent/Exchanger$Node;
ifnonnull 7
5: aload 0
aload 6
iconst_1
lload 7
invokevirtual java.util.concurrent.Exchanger.slotExchange:(Ljava/lang/Object;ZJ)Ljava/lang/Object;
dup
astore 5
start local 5 6: ifnonnull 11
end local 5 7: StackMap locals: java.util.concurrent.Exchanger java.lang.Object long java.util.concurrent.TimeUnit top java.lang.Object long
StackMap stack:
invokestatic java.lang.Thread.interrupted:()Z
ifne 10
8: aload 0
aload 6
iconst_1
lload 7
invokevirtual java.util.concurrent.Exchanger.arenaExchange:(Ljava/lang/Object;ZJ)Ljava/lang/Object;
dup
astore 5
start local 5 9: ifnonnull 11
end local 5 10: StackMap locals:
StackMap stack:
new java.lang.InterruptedException
dup
invokespecial java.lang.InterruptedException.<init>:()V
athrow
start local 5 11: StackMap locals: java.util.concurrent.Exchanger java.lang.Object long java.util.concurrent.TimeUnit java.lang.Object java.lang.Object long
StackMap stack:
aload 5
getstatic java.util.concurrent.Exchanger.TIMED_OUT:Ljava/lang/Object;
if_acmpne 13
12: new java.util.concurrent.TimeoutException
dup
invokespecial java.util.concurrent.TimeoutException.<init>:()V
athrow
13: StackMap locals:
StackMap stack:
aload 5
getstatic java.util.concurrent.Exchanger.NULL_ITEM:Ljava/lang/Object;
if_acmpne 14
aconst_null
goto 15
StackMap locals:
StackMap stack:
14: aload 5
StackMap locals:
StackMap stack: java.lang.Object
15: areturn
end local 7 end local 6 end local 5 end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Ljava/util/concurrent/Exchanger<TV;>;
0 16 1 x TV;
0 16 2 timeout J
0 16 4 unit Ljava/util/concurrent/TimeUnit;
6 7 5 v Ljava/lang/Object;
9 10 5 v Ljava/lang/Object;
11 16 5 v Ljava/lang/Object;
3 16 6 item Ljava/lang/Object;
4 16 7 ns J
Exceptions:
throws java.lang.InterruptedException, java.util.concurrent.TimeoutException
Signature: (TV;JLjava/util/concurrent/TimeUnit;)TV;
MethodParameters:
Name Flags
x
timeout
unit
}
Signature: <V:Ljava/lang/Object;>Ljava/lang/Object;
SourceFile: "Exchanger.java"
NestMembers:
java.util.concurrent.Exchanger$Node java.util.concurrent.Exchanger$Participant
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
final Node = java.util.concurrent.Exchanger$Node of java.util.concurrent.Exchanger
final Participant = java.util.concurrent.Exchanger$Participant of java.util.concurrent.Exchanger