abstract class com.google.common.util.concurrent.InterruptibleTask<T> extends java.util.concurrent.atomic.AtomicReference<java.lang.Runnable> implements java.lang.Runnable
minor version: 0
major version: 59
flags: flags: (0x0420) ACC_SUPER, ACC_ABSTRACT
this_class: com.google.common.util.concurrent.InterruptibleTask
super_class: java.util.concurrent.atomic.AtomicReference
{
private static final java.lang.Runnable DONE;
descriptor: Ljava/lang/Runnable;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final java.lang.Runnable INTERRUPTING;
descriptor: Ljava/lang/Runnable;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final java.lang.Runnable PARKED;
descriptor: Ljava/lang/Runnable;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final int MAX_BUSY_WAIT_SPINS;
descriptor: I
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: 1000
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: new com.google.common.util.concurrent.InterruptibleTask$DoNothingRunnable
dup
invokespecial com.google.common.util.concurrent.InterruptibleTask$DoNothingRunnable.<init>:()V
putstatic com.google.common.util.concurrent.InterruptibleTask.DONE:Ljava/lang/Runnable;
1: new com.google.common.util.concurrent.InterruptibleTask$DoNothingRunnable
dup
invokespecial com.google.common.util.concurrent.InterruptibleTask$DoNothingRunnable.<init>:()V
putstatic com.google.common.util.concurrent.InterruptibleTask.INTERRUPTING:Ljava/lang/Runnable;
2: new com.google.common.util.concurrent.InterruptibleTask$DoNothingRunnable
dup
invokespecial com.google.common.util.concurrent.InterruptibleTask$DoNothingRunnable.<init>:()V
putstatic com.google.common.util.concurrent.InterruptibleTask.PARKED:Ljava/lang/Runnable;
3: return
LocalVariableTable:
Start End Slot Name Signature
void <init>();
descriptor: ()V
flags: (0x0000)
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokespecial java.util.concurrent.atomic.AtomicReference.<init>:()V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/google/common/util/concurrent/InterruptibleTask<TT;>;
public final void run();
descriptor: ()V
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=10, args_size=1
start local 0 0: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
astore 1
start local 1 1: aload 0
aconst_null
aload 1
invokevirtual com.google.common.util.concurrent.InterruptibleTask.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
ifne 3
2: return
3: StackMap locals: java.lang.Thread
StackMap stack:
aload 0
invokevirtual com.google.common.util.concurrent.InterruptibleTask.isDone:()Z
ifeq 4
iconst_0
goto 5
StackMap locals:
StackMap stack:
4: iconst_1
StackMap locals:
StackMap stack: int
5: istore 2
start local 2 6: aconst_null
astore 3
start local 3 7: aconst_null
astore 4
start local 4 8: iload 2
ifeq 55
9: aload 0
invokevirtual com.google.common.util.concurrent.InterruptibleTask.runInterruptibly:()Ljava/lang/Object;
astore 3
10: goto 55
StackMap locals: com.google.common.util.concurrent.InterruptibleTask java.lang.Thread int java.lang.Object java.lang.Throwable
StackMap stack: java.lang.Throwable
11: astore 5
start local 5 12: aload 5
astore 4
end local 5 13: aload 0
aload 1
getstatic com.google.common.util.concurrent.InterruptibleTask.DONE:Ljava/lang/Runnable;
invokevirtual com.google.common.util.concurrent.InterruptibleTask.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
ifne 31
14: iconst_0
istore 7
start local 7 15: iconst_0
istore 8
start local 8 16: aload 0
invokevirtual com.google.common.util.concurrent.InterruptibleTask.get:()Ljava/lang/Object;
checkcast java.lang.Runnable
astore 9
start local 9 17: goto 28
18: StackMap locals: com.google.common.util.concurrent.InterruptibleTask java.lang.Thread int java.lang.Object java.lang.Throwable top top int int java.lang.Runnable
StackMap stack:
iinc 8 1
19: iload 8
sipush 1000
if_icmple 26
20: aload 9
getstatic com.google.common.util.concurrent.InterruptibleTask.PARKED:Ljava/lang/Runnable;
if_acmpeq 21
aload 0
getstatic com.google.common.util.concurrent.InterruptibleTask.INTERRUPTING:Ljava/lang/Runnable;
getstatic com.google.common.util.concurrent.InterruptibleTask.PARKED:Ljava/lang/Runnable;
invokevirtual com.google.common.util.concurrent.InterruptibleTask.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
ifeq 27
21: StackMap locals:
StackMap stack:
invokestatic java.lang.Thread.interrupted:()Z
ifne 22
iload 7
ifne 22
iconst_0
goto 23
StackMap locals:
StackMap stack:
22: iconst_1
StackMap locals:
StackMap stack: int
23: istore 7
24: aload 0
invokestatic java.util.concurrent.locks.LockSupport.park:(Ljava/lang/Object;)V
25: goto 27
26: StackMap locals:
StackMap stack:
invokestatic java.lang.Thread.yield:()V
27: StackMap locals:
StackMap stack:
aload 0
invokevirtual com.google.common.util.concurrent.InterruptibleTask.get:()Ljava/lang/Object;
checkcast java.lang.Runnable
astore 9
28: StackMap locals:
StackMap stack:
aload 9
getstatic com.google.common.util.concurrent.InterruptibleTask.INTERRUPTING:Ljava/lang/Runnable;
if_acmpeq 18
aload 9
getstatic com.google.common.util.concurrent.InterruptibleTask.PARKED:Ljava/lang/Runnable;
if_acmpeq 18
29: iload 7
ifeq 31
30: aload 1
invokevirtual java.lang.Thread.interrupt:()V
end local 9 end local 8 end local 7 31: StackMap locals: com.google.common.util.concurrent.InterruptibleTask java.lang.Thread int java.lang.Object java.lang.Throwable
StackMap stack:
iload 2
ifeq 75
32: aload 0
aload 3
aload 4
invokevirtual com.google.common.util.concurrent.InterruptibleTask.afterRanInterruptibly:(Ljava/lang/Object;Ljava/lang/Throwable;)V
goto 75
33: StackMap locals:
StackMap stack: java.lang.Throwable
astore 6
34: aload 0
aload 1
getstatic com.google.common.util.concurrent.InterruptibleTask.DONE:Ljava/lang/Runnable;
invokevirtual com.google.common.util.concurrent.InterruptibleTask.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
ifne 52
35: iconst_0
istore 7
start local 7 36: iconst_0
istore 8
start local 8 37: aload 0
invokevirtual com.google.common.util.concurrent.InterruptibleTask.get:()Ljava/lang/Object;
checkcast java.lang.Runnable
astore 9
start local 9 38: goto 49
39: StackMap locals: com.google.common.util.concurrent.InterruptibleTask java.lang.Thread int java.lang.Object java.lang.Throwable top java.lang.Throwable int int java.lang.Runnable
StackMap stack:
iinc 8 1
40: iload 8
sipush 1000
if_icmple 47
41: aload 9
getstatic com.google.common.util.concurrent.InterruptibleTask.PARKED:Ljava/lang/Runnable;
if_acmpeq 42
aload 0
getstatic com.google.common.util.concurrent.InterruptibleTask.INTERRUPTING:Ljava/lang/Runnable;
getstatic com.google.common.util.concurrent.InterruptibleTask.PARKED:Ljava/lang/Runnable;
invokevirtual com.google.common.util.concurrent.InterruptibleTask.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
ifeq 48
42: StackMap locals:
StackMap stack:
invokestatic java.lang.Thread.interrupted:()Z
ifne 43
iload 7
ifne 43
iconst_0
goto 44
StackMap locals:
StackMap stack:
43: iconst_1
StackMap locals:
StackMap stack: int
44: istore 7
45: aload 0
invokestatic java.util.concurrent.locks.LockSupport.park:(Ljava/lang/Object;)V
46: goto 48
47: StackMap locals:
StackMap stack:
invokestatic java.lang.Thread.yield:()V
48: StackMap locals:
StackMap stack:
aload 0
invokevirtual com.google.common.util.concurrent.InterruptibleTask.get:()Ljava/lang/Object;
checkcast java.lang.Runnable
astore 9
49: StackMap locals:
StackMap stack:
aload 9
getstatic com.google.common.util.concurrent.InterruptibleTask.INTERRUPTING:Ljava/lang/Runnable;
if_acmpeq 39
aload 9
getstatic com.google.common.util.concurrent.InterruptibleTask.PARKED:Ljava/lang/Runnable;
if_acmpeq 39
50: iload 7
ifeq 52
51: aload 1
invokevirtual java.lang.Thread.interrupt:()V
end local 9 end local 8 end local 7 52: StackMap locals:
StackMap stack:
iload 2
ifeq 54
53: aload 0
aload 3
aload 4
invokevirtual com.google.common.util.concurrent.InterruptibleTask.afterRanInterruptibly:(Ljava/lang/Object;Ljava/lang/Throwable;)V
54: StackMap locals:
StackMap stack:
aload 6
athrow
55: StackMap locals: com.google.common.util.concurrent.InterruptibleTask java.lang.Thread int java.lang.Object java.lang.Throwable
StackMap stack:
aload 0
aload 1
getstatic com.google.common.util.concurrent.InterruptibleTask.DONE:Ljava/lang/Runnable;
invokevirtual com.google.common.util.concurrent.InterruptibleTask.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
ifne 73
56: iconst_0
istore 7
start local 7 57: iconst_0
istore 8
start local 8 58: aload 0
invokevirtual com.google.common.util.concurrent.InterruptibleTask.get:()Ljava/lang/Object;
checkcast java.lang.Runnable
astore 9
start local 9 59: goto 70
60: StackMap locals: com.google.common.util.concurrent.InterruptibleTask java.lang.Thread int java.lang.Object java.lang.Throwable top top int int java.lang.Runnable
StackMap stack:
iinc 8 1
61: iload 8
sipush 1000
if_icmple 68
62: aload 9
getstatic com.google.common.util.concurrent.InterruptibleTask.PARKED:Ljava/lang/Runnable;
if_acmpeq 63
aload 0
getstatic com.google.common.util.concurrent.InterruptibleTask.INTERRUPTING:Ljava/lang/Runnable;
getstatic com.google.common.util.concurrent.InterruptibleTask.PARKED:Ljava/lang/Runnable;
invokevirtual com.google.common.util.concurrent.InterruptibleTask.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
ifeq 69
63: StackMap locals:
StackMap stack:
invokestatic java.lang.Thread.interrupted:()Z
ifne 64
iload 7
ifne 64
iconst_0
goto 65
StackMap locals:
StackMap stack:
64: iconst_1
StackMap locals:
StackMap stack: int
65: istore 7
66: aload 0
invokestatic java.util.concurrent.locks.LockSupport.park:(Ljava/lang/Object;)V
67: goto 69
68: StackMap locals:
StackMap stack:
invokestatic java.lang.Thread.yield:()V
69: StackMap locals:
StackMap stack:
aload 0
invokevirtual com.google.common.util.concurrent.InterruptibleTask.get:()Ljava/lang/Object;
checkcast java.lang.Runnable
astore 9
70: StackMap locals:
StackMap stack:
aload 9
getstatic com.google.common.util.concurrent.InterruptibleTask.INTERRUPTING:Ljava/lang/Runnable;
if_acmpeq 60
aload 9
getstatic com.google.common.util.concurrent.InterruptibleTask.PARKED:Ljava/lang/Runnable;
if_acmpeq 60
71: iload 7
ifeq 73
72: aload 1
invokevirtual java.lang.Thread.interrupt:()V
end local 9 end local 8 end local 7 73: StackMap locals: com.google.common.util.concurrent.InterruptibleTask java.lang.Thread int java.lang.Object java.lang.Throwable
StackMap stack:
iload 2
ifeq 75
74: aload 0
aload 3
aload 4
invokevirtual com.google.common.util.concurrent.InterruptibleTask.afterRanInterruptibly:(Ljava/lang/Object;Ljava/lang/Throwable;)V
75: StackMap locals:
StackMap stack:
return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 76 0 this Lcom/google/common/util/concurrent/InterruptibleTask<TT;>;
1 76 1 currentThread Ljava/lang/Thread;
6 76 2 run Z
7 76 3 result TT;
8 76 4 error Ljava/lang/Throwable;
12 13 5 t Ljava/lang/Throwable;
15 31 7 restoreInterruptedBit Z
36 52 7 restoreInterruptedBit Z
57 73 7 restoreInterruptedBit Z
16 31 8 spinCount I
37 52 8 spinCount I
58 73 8 spinCount I
17 31 9 state Ljava/lang/Runnable;
38 52 9 state Ljava/lang/Runnable;
59 73 9 state Ljava/lang/Runnable;
Exception table:
from to target type
8 10 11 Class java.lang.Throwable
8 13 33 any
abstract boolean isDone();
descriptor: ()Z
flags: (0x0400) ACC_ABSTRACT
abstract T runInterruptibly();
descriptor: ()Ljava/lang/Object;
flags: (0x0400) ACC_ABSTRACT
Exceptions:
throws java.lang.Exception
Signature: ()TT;
abstract void afterRanInterruptibly(T, java.lang.Throwable);
descriptor: (Ljava/lang/Object;Ljava/lang/Throwable;)V
flags: (0x0400) ACC_ABSTRACT
Signature: (TT;Ljava/lang/Throwable;)V
RuntimeVisibleTypeAnnotations:
METHOD_FORMAL_PARAMETER
org.checkerframework.checker.nullness.qual.Nullable()
METHOD_FORMAL_PARAMETER
org.checkerframework.checker.nullness.qual.Nullable()
MethodParameters:
Name Flags
result
error
final void interruptTask();
descriptor: ()V
flags: (0x0010) ACC_FINAL
Code:
stack=3, locals=4, args_size=1
start local 0 0: aload 0
invokevirtual com.google.common.util.concurrent.InterruptibleTask.get:()Ljava/lang/Object;
checkcast java.lang.Runnable
astore 1
start local 1 1: aload 1
instanceof java.lang.Thread
ifeq 12
aload 0
aload 1
getstatic com.google.common.util.concurrent.InterruptibleTask.INTERRUPTING:Ljava/lang/Runnable;
invokevirtual com.google.common.util.concurrent.InterruptibleTask.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
ifeq 12
2: aload 1
checkcast java.lang.Thread
invokevirtual java.lang.Thread.interrupt:()V
3: goto 9
StackMap locals: com.google.common.util.concurrent.InterruptibleTask java.lang.Runnable
StackMap stack: java.lang.Throwable
4: astore 2
5: aload 0
getstatic com.google.common.util.concurrent.InterruptibleTask.DONE:Ljava/lang/Runnable;
invokevirtual com.google.common.util.concurrent.InterruptibleTask.getAndSet:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.Runnable
astore 3
start local 3 6: aload 3
getstatic com.google.common.util.concurrent.InterruptibleTask.PARKED:Ljava/lang/Runnable;
if_acmpne 8
7: aload 1
checkcast java.lang.Thread
invokestatic java.util.concurrent.locks.LockSupport.unpark:(Ljava/lang/Thread;)V
end local 3 8: StackMap locals: java.lang.Throwable
StackMap stack:
aload 2
athrow
9: StackMap locals:
StackMap stack:
aload 0
getstatic com.google.common.util.concurrent.InterruptibleTask.DONE:Ljava/lang/Runnable;
invokevirtual com.google.common.util.concurrent.InterruptibleTask.getAndSet:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.Runnable
astore 3
start local 3 10: aload 3
getstatic com.google.common.util.concurrent.InterruptibleTask.PARKED:Ljava/lang/Runnable;
if_acmpne 12
11: aload 1
checkcast java.lang.Thread
invokestatic java.util.concurrent.locks.LockSupport.unpark:(Ljava/lang/Thread;)V
end local 3 12: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lcom/google/common/util/concurrent/InterruptibleTask<TT;>;
1 13 1 currentRunner Ljava/lang/Runnable;
6 8 3 prev Ljava/lang/Runnable;
10 12 3 prev Ljava/lang/Runnable;
Exception table:
from to target type
2 4 4 any
public final java.lang.String toString();
descriptor: ()Ljava/lang/String;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=3, locals=3, args_size=1
start local 0 0: aload 0
invokevirtual com.google.common.util.concurrent.InterruptibleTask.get:()Ljava/lang/Object;
checkcast java.lang.Runnable
astore 1
start local 1 1: aload 1
getstatic com.google.common.util.concurrent.InterruptibleTask.DONE:Ljava/lang/Runnable;
if_acmpne 4
2: ldc "running=[DONE]"
astore 2
start local 2 3: goto 11
end local 2 StackMap locals: java.lang.Runnable
StackMap stack:
4: aload 1
getstatic com.google.common.util.concurrent.InterruptibleTask.INTERRUPTING:Ljava/lang/Runnable;
if_acmpne 7
5: ldc "running=[INTERRUPTED]"
astore 2
start local 2 6: goto 11
end local 2 StackMap locals:
StackMap stack:
7: aload 1
instanceof java.lang.Thread
ifeq 10
8: new java.lang.StringBuilder
dup
ldc "running=[RUNNING ON "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
checkcast java.lang.Thread
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;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
astore 2
start local 2 9: goto 11
end local 2 10: StackMap locals:
StackMap stack:
ldc "running=[NOT STARTED YET]"
astore 2
start local 2 11: StackMap locals: java.lang.String
StackMap stack:
new java.lang.StringBuilder
dup
aload 2
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 0
invokevirtual com.google.common.util.concurrent.InterruptibleTask.toPendingString:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lcom/google/common/util/concurrent/InterruptibleTask<TT;>;
1 12 1 state Ljava/lang/Runnable;
3 4 2 result Ljava/lang/String;
6 7 2 result Ljava/lang/String;
9 10 2 result Ljava/lang/String;
11 12 2 result Ljava/lang/String;
abstract java.lang.String toPendingString();
descriptor: ()Ljava/lang/String;
flags: (0x0400) ACC_ABSTRACT
}
Signature: <T:Ljava/lang/Object;>Ljava/util/concurrent/atomic/AtomicReference<Ljava/lang/Runnable;>;Ljava/lang/Runnable;
SourceFile: "InterruptibleTask.java"
NestMembers:
com.google.common.util.concurrent.InterruptibleTask$DoNothingRunnable
InnerClasses:
private final DoNothingRunnable = com.google.common.util.concurrent.InterruptibleTask$DoNothingRunnable of com.google.common.util.concurrent.InterruptibleTask
public final Level = com.google.j2objc.annotations.ReflectionSupport$Level of com.google.j2objc.annotations.ReflectionSupport
RuntimeInvisibleAnnotations:
com.google.common.annotations.GwtCompatible(emulated = true)
com.google.j2objc.annotations.ReflectionSupport(value = com.google.j2objc.annotations.ReflectionSupport$Level.FULL:Lcom/google/j2objc/annotations/ReflectionSupport$Level;)