public final class com.google.common.util.concurrent.Uninterruptibles
minor version: 0
major version: 59
flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
this_class: com.google.common.util.concurrent.Uninterruptibles
super_class: java.lang.Object
{
public static void awaitUninterruptibly(java.util.concurrent.CountDownLatch);
descriptor: (Ljava/util/concurrent/CountDownLatch;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=3, args_size=1
start local 0 0: iconst_0
istore 1
start local 1 1: StackMap locals: int
StackMap stack:
aload 0
invokevirtual java.util.concurrent.CountDownLatch.await:()V
2: iload 1
ifeq 4
3: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
4: StackMap locals:
StackMap stack:
return
5: StackMap locals:
StackMap stack: java.lang.InterruptedException
pop
6: iconst_1
istore 1
7: goto 1
8: StackMap locals:
StackMap stack: java.lang.Throwable
astore 2
9: iload 1
ifeq 11
10: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
11: StackMap locals: java.lang.Throwable
StackMap stack:
aload 2
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 latch Ljava/util/concurrent/CountDownLatch;
1 12 1 interrupted Z
Exception table:
from to target type
1 2 5 Class java.lang.InterruptedException
1 2 8 any
5 8 8 any
RuntimeInvisibleAnnotations:
com.google.common.annotations.GwtIncompatible()
MethodParameters:
Name Flags
latch
public static boolean awaitUninterruptibly(java.util.concurrent.CountDownLatch, java.time.Duration);
descriptor: (Ljava/util/concurrent/CountDownLatch;Ljava/time/Duration;)Z
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic com.google.common.util.concurrent.Internal.toNanosSaturated:(Ljava/time/Duration;)J
getstatic java.util.concurrent.TimeUnit.NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invokestatic com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly:(Ljava/util/concurrent/CountDownLatch;JLjava/util/concurrent/TimeUnit;)Z
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 latch Ljava/util/concurrent/CountDownLatch;
0 1 1 timeout Ljava/time/Duration;
RuntimeInvisibleAnnotations:
com.google.errorprone.annotations.CanIgnoreReturnValue()
com.google.common.annotations.GwtIncompatible()
com.google.common.annotations.Beta()
MethodParameters:
Name Flags
latch
timeout
public static boolean awaitUninterruptibly(java.util.concurrent.CountDownLatch, long, java.util.concurrent.TimeUnit);
descriptor: (Ljava/util/concurrent/CountDownLatch;JLjava/util/concurrent/TimeUnit;)Z
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=11, args_size=3
start local 0 start local 1 start local 3 0: iconst_0
istore 4
start local 4 1: aload 3
lload 1
invokevirtual java.util.concurrent.TimeUnit.toNanos:(J)J
lstore 5
start local 5 2: invokestatic java.lang.System.nanoTime:()J
lload 5
ladd
lstore 7
start local 7 3: StackMap locals: int long long
StackMap stack:
aload 0
lload 5
getstatic java.util.concurrent.TimeUnit.NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invokevirtual java.util.concurrent.CountDownLatch.await:(JLjava/util/concurrent/TimeUnit;)Z
istore 10
4: iload 4
ifeq 6
5: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
6: StackMap locals: java.util.concurrent.CountDownLatch long java.util.concurrent.TimeUnit int long long top int
StackMap stack:
iload 10
ireturn
7: StackMap locals: java.util.concurrent.CountDownLatch long java.util.concurrent.TimeUnit int long long
StackMap stack: java.lang.InterruptedException
pop
8: iconst_1
istore 4
9: lload 7
invokestatic java.lang.System.nanoTime:()J
lsub
lstore 5
10: goto 3
end local 7 end local 5 11: StackMap locals: java.util.concurrent.CountDownLatch long java.util.concurrent.TimeUnit int
StackMap stack: java.lang.Throwable
astore 9
12: iload 4
ifeq 14
13: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
14: StackMap locals: java.util.concurrent.CountDownLatch long java.util.concurrent.TimeUnit int top top top top java.lang.Throwable
StackMap stack:
aload 9
athrow
end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 latch Ljava/util/concurrent/CountDownLatch;
0 15 1 timeout J
0 15 3 unit Ljava/util/concurrent/TimeUnit;
1 15 4 interrupted Z
2 11 5 remainingNanos J
3 11 7 end J
Exception table:
from to target type
3 4 7 Class java.lang.InterruptedException
1 4 11 any
7 11 11 any
RuntimeInvisibleAnnotations:
com.google.errorprone.annotations.CanIgnoreReturnValue()
com.google.common.annotations.GwtIncompatible()
MethodParameters:
Name Flags
latch
timeout
unit
public static boolean awaitUninterruptibly(java.util.concurrent.locks.Condition, java.time.Duration);
descriptor: (Ljava/util/concurrent/locks/Condition;Ljava/time/Duration;)Z
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic com.google.common.util.concurrent.Internal.toNanosSaturated:(Ljava/time/Duration;)J
getstatic java.util.concurrent.TimeUnit.NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invokestatic com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly:(Ljava/util/concurrent/locks/Condition;JLjava/util/concurrent/TimeUnit;)Z
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 condition Ljava/util/concurrent/locks/Condition;
0 1 1 timeout Ljava/time/Duration;
RuntimeInvisibleAnnotations:
com.google.common.annotations.GwtIncompatible()
com.google.common.annotations.Beta()
MethodParameters:
Name Flags
condition
timeout
public static boolean awaitUninterruptibly(java.util.concurrent.locks.Condition, long, java.util.concurrent.TimeUnit);
descriptor: (Ljava/util/concurrent/locks/Condition;JLjava/util/concurrent/TimeUnit;)Z
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=11, args_size=3
start local 0 start local 1 start local 3 0: iconst_0
istore 4
start local 4 1: aload 3
lload 1
invokevirtual java.util.concurrent.TimeUnit.toNanos:(J)J
lstore 5
start local 5 2: invokestatic java.lang.System.nanoTime:()J
lload 5
ladd
lstore 7
start local 7 3: StackMap locals: int long long
StackMap stack:
aload 0
lload 5
getstatic java.util.concurrent.TimeUnit.NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invokeinterface java.util.concurrent.locks.Condition.await:(JLjava/util/concurrent/TimeUnit;)Z
istore 10
4: iload 4
ifeq 6
5: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
6: StackMap locals: java.util.concurrent.locks.Condition long java.util.concurrent.TimeUnit int long long top int
StackMap stack:
iload 10
ireturn
7: StackMap locals: java.util.concurrent.locks.Condition long java.util.concurrent.TimeUnit int long long
StackMap stack: java.lang.InterruptedException
pop
8: iconst_1
istore 4
9: lload 7
invokestatic java.lang.System.nanoTime:()J
lsub
lstore 5
10: goto 3
end local 7 end local 5 11: StackMap locals: java.util.concurrent.locks.Condition long java.util.concurrent.TimeUnit int
StackMap stack: java.lang.Throwable
astore 9
12: iload 4
ifeq 14
13: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
14: StackMap locals: java.util.concurrent.locks.Condition long java.util.concurrent.TimeUnit int top top top top java.lang.Throwable
StackMap stack:
aload 9
athrow
end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 condition Ljava/util/concurrent/locks/Condition;
0 15 1 timeout J
0 15 3 unit Ljava/util/concurrent/TimeUnit;
1 15 4 interrupted Z
2 11 5 remainingNanos J
3 11 7 end J
Exception table:
from to target type
3 4 7 Class java.lang.InterruptedException
1 4 11 any
7 11 11 any
RuntimeInvisibleAnnotations:
com.google.common.annotations.GwtIncompatible()
MethodParameters:
Name Flags
condition
timeout
unit
public static void joinUninterruptibly(java.lang.Thread);
descriptor: (Ljava/lang/Thread;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=3, args_size=1
start local 0 0: iconst_0
istore 1
start local 1 1: StackMap locals: int
StackMap stack:
aload 0
invokevirtual java.lang.Thread.join:()V
2: iload 1
ifeq 4
3: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
4: StackMap locals:
StackMap stack:
return
5: StackMap locals:
StackMap stack: java.lang.InterruptedException
pop
6: iconst_1
istore 1
7: goto 1
8: StackMap locals:
StackMap stack: java.lang.Throwable
astore 2
9: iload 1
ifeq 11
10: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
11: StackMap locals: java.lang.Throwable
StackMap stack:
aload 2
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 toJoin Ljava/lang/Thread;
1 12 1 interrupted Z
Exception table:
from to target type
1 2 5 Class java.lang.InterruptedException
1 2 8 any
5 8 8 any
RuntimeInvisibleAnnotations:
com.google.common.annotations.GwtIncompatible()
MethodParameters:
Name Flags
toJoin
public static void joinUninterruptibly(java.lang.Thread, java.time.Duration);
descriptor: (Ljava/lang/Thread;Ljava/time/Duration;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic com.google.common.util.concurrent.Internal.toNanosSaturated:(Ljava/time/Duration;)J
getstatic java.util.concurrent.TimeUnit.NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invokestatic com.google.common.util.concurrent.Uninterruptibles.joinUninterruptibly:(Ljava/lang/Thread;JLjava/util/concurrent/TimeUnit;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 toJoin Ljava/lang/Thread;
0 2 1 timeout Ljava/time/Duration;
RuntimeInvisibleAnnotations:
com.google.common.annotations.GwtIncompatible()
com.google.common.annotations.Beta()
MethodParameters:
Name Flags
toJoin
timeout
public static void joinUninterruptibly(java.lang.Thread, long, java.util.concurrent.TimeUnit);
descriptor: (Ljava/lang/Thread;JLjava/util/concurrent/TimeUnit;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=10, args_size=3
start local 0 start local 1 start local 3 0: aload 0
invokestatic com.google.common.base.Preconditions.checkNotNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
1: iconst_0
istore 4
start local 4 2: aload 3
lload 1
invokevirtual java.util.concurrent.TimeUnit.toNanos:(J)J
lstore 5
start local 5 3: invokestatic java.lang.System.nanoTime:()J
lload 5
ladd
lstore 7
start local 7 4: StackMap locals: int long long
StackMap stack:
getstatic java.util.concurrent.TimeUnit.NANOSECONDS:Ljava/util/concurrent/TimeUnit;
aload 0
lload 5
invokevirtual java.util.concurrent.TimeUnit.timedJoin:(Ljava/lang/Thread;J)V
5: iload 4
ifeq 7
6: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
7: StackMap locals:
StackMap stack:
return
8: StackMap locals:
StackMap stack: java.lang.InterruptedException
pop
9: iconst_1
istore 4
10: lload 7
invokestatic java.lang.System.nanoTime:()J
lsub
lstore 5
11: goto 4
end local 7 end local 5 12: StackMap locals: java.lang.Thread long java.util.concurrent.TimeUnit int
StackMap stack: java.lang.Throwable
astore 9
13: iload 4
ifeq 15
14: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
15: StackMap locals: java.lang.Thread long java.util.concurrent.TimeUnit int top top top top java.lang.Throwable
StackMap stack:
aload 9
athrow
end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 toJoin Ljava/lang/Thread;
0 16 1 timeout J
0 16 3 unit Ljava/util/concurrent/TimeUnit;
2 16 4 interrupted Z
3 12 5 remainingNanos J
4 12 7 end J
Exception table:
from to target type
4 5 8 Class java.lang.InterruptedException
2 5 12 any
8 12 12 any
RuntimeInvisibleAnnotations:
com.google.common.annotations.GwtIncompatible()
MethodParameters:
Name Flags
toJoin
timeout
unit
public static <V> V getUninterruptibly(java.util.concurrent.Future<V>);
descriptor: (Ljava/util/concurrent/Future;)Ljava/lang/Object;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=4, args_size=1
start local 0 0: iconst_0
istore 1
start local 1 1: StackMap locals: int
StackMap stack:
aload 0
invokeinterface java.util.concurrent.Future.get:()Ljava/lang/Object;
astore 3
2: iload 1
ifeq 4
3: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
4: StackMap locals: java.util.concurrent.Future int top java.lang.Object
StackMap stack:
aload 3
areturn
5: StackMap locals: java.util.concurrent.Future int
StackMap stack: java.lang.InterruptedException
pop
6: iconst_1
istore 1
7: goto 1
8: StackMap locals:
StackMap stack: java.lang.Throwable
astore 2
9: iload 1
ifeq 11
10: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
11: StackMap locals: java.lang.Throwable
StackMap stack:
aload 2
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 future Ljava/util/concurrent/Future<TV;>;
1 12 1 interrupted Z
Exception table:
from to target type
1 2 5 Class java.lang.InterruptedException
1 2 8 any
5 8 8 any
Exceptions:
throws java.util.concurrent.ExecutionException
Signature: <V:Ljava/lang/Object;>(Ljava/util/concurrent/Future<TV;>;)TV;
RuntimeInvisibleAnnotations:
com.google.errorprone.annotations.CanIgnoreReturnValue()
MethodParameters:
Name Flags
future
public static <V> V getUninterruptibly(java.util.concurrent.Future<V>, java.time.Duration);
descriptor: (Ljava/util/concurrent/Future;Ljava/time/Duration;)Ljava/lang/Object;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic com.google.common.util.concurrent.Internal.toNanosSaturated:(Ljava/time/Duration;)J
getstatic java.util.concurrent.TimeUnit.NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invokestatic com.google.common.util.concurrent.Uninterruptibles.getUninterruptibly:(Ljava/util/concurrent/Future;JLjava/util/concurrent/TimeUnit;)Ljava/lang/Object;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 future Ljava/util/concurrent/Future<TV;>;
0 1 1 timeout Ljava/time/Duration;
Exceptions:
throws java.util.concurrent.ExecutionException, java.util.concurrent.TimeoutException
Signature: <V:Ljava/lang/Object;>(Ljava/util/concurrent/Future<TV;>;Ljava/time/Duration;)TV;
RuntimeInvisibleAnnotations:
com.google.errorprone.annotations.CanIgnoreReturnValue()
com.google.common.annotations.GwtIncompatible()
com.google.common.annotations.Beta()
MethodParameters:
Name Flags
future
timeout
public static <V> V getUninterruptibly(java.util.concurrent.Future<V>, long, java.util.concurrent.TimeUnit);
descriptor: (Ljava/util/concurrent/Future;JLjava/util/concurrent/TimeUnit;)Ljava/lang/Object;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=11, args_size=3
start local 0 start local 1 start local 3 0: iconst_0
istore 4
start local 4 1: aload 3
lload 1
invokevirtual java.util.concurrent.TimeUnit.toNanos:(J)J
lstore 5
start local 5 2: invokestatic java.lang.System.nanoTime:()J
lload 5
ladd
lstore 7
start local 7 3: StackMap locals: int long long
StackMap stack:
aload 0
lload 5
getstatic java.util.concurrent.TimeUnit.NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invokeinterface java.util.concurrent.Future.get:(JLjava/util/concurrent/TimeUnit;)Ljava/lang/Object;
astore 10
4: iload 4
ifeq 6
5: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
6: StackMap locals: java.util.concurrent.Future long java.util.concurrent.TimeUnit int long long top java.lang.Object
StackMap stack:
aload 10
areturn
7: StackMap locals: java.util.concurrent.Future long java.util.concurrent.TimeUnit int long long
StackMap stack: java.lang.InterruptedException
pop
8: iconst_1
istore 4
9: lload 7
invokestatic java.lang.System.nanoTime:()J
lsub
lstore 5
10: goto 3
end local 7 end local 5 11: StackMap locals: java.util.concurrent.Future long java.util.concurrent.TimeUnit int
StackMap stack: java.lang.Throwable
astore 9
12: iload 4
ifeq 14
13: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
14: StackMap locals: java.util.concurrent.Future long java.util.concurrent.TimeUnit int top top top top java.lang.Throwable
StackMap stack:
aload 9
athrow
end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 future Ljava/util/concurrent/Future<TV;>;
0 15 1 timeout J
0 15 3 unit Ljava/util/concurrent/TimeUnit;
1 15 4 interrupted Z
2 11 5 remainingNanos J
3 11 7 end J
Exception table:
from to target type
3 4 7 Class java.lang.InterruptedException
1 4 11 any
7 11 11 any
Exceptions:
throws java.util.concurrent.ExecutionException, java.util.concurrent.TimeoutException
Signature: <V:Ljava/lang/Object;>(Ljava/util/concurrent/Future<TV;>;JLjava/util/concurrent/TimeUnit;)TV;
RuntimeInvisibleAnnotations:
com.google.errorprone.annotations.CanIgnoreReturnValue()
com.google.common.annotations.GwtIncompatible()
MethodParameters:
Name Flags
future
timeout
unit
public static <E> E takeUninterruptibly(java.util.concurrent.BlockingQueue<E>);
descriptor: (Ljava/util/concurrent/BlockingQueue;)Ljava/lang/Object;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=4, args_size=1
start local 0 0: iconst_0
istore 1
start local 1 1: StackMap locals: int
StackMap stack:
aload 0
invokeinterface java.util.concurrent.BlockingQueue.take:()Ljava/lang/Object;
astore 3
2: iload 1
ifeq 4
3: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
4: StackMap locals: java.util.concurrent.BlockingQueue int top java.lang.Object
StackMap stack:
aload 3
areturn
5: StackMap locals: java.util.concurrent.BlockingQueue int
StackMap stack: java.lang.InterruptedException
pop
6: iconst_1
istore 1
7: goto 1
8: StackMap locals:
StackMap stack: java.lang.Throwable
astore 2
9: iload 1
ifeq 11
10: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
11: StackMap locals: java.lang.Throwable
StackMap stack:
aload 2
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 queue Ljava/util/concurrent/BlockingQueue<TE;>;
1 12 1 interrupted Z
Exception table:
from to target type
1 2 5 Class java.lang.InterruptedException
1 2 8 any
5 8 8 any
Signature: <E:Ljava/lang/Object;>(Ljava/util/concurrent/BlockingQueue<TE;>;)TE;
RuntimeInvisibleAnnotations:
com.google.common.annotations.GwtIncompatible()
MethodParameters:
Name Flags
queue
public static <E> void putUninterruptibly(java.util.concurrent.BlockingQueue<E>, );
descriptor: (Ljava/util/concurrent/BlockingQueue;Ljava/lang/Object;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=4, args_size=2
start local 0 start local 1 0: iconst_0
istore 2
start local 2 1: StackMap locals: int
StackMap stack:
aload 0
aload 1
invokeinterface java.util.concurrent.BlockingQueue.put:(Ljava/lang/Object;)V
2: iload 2
ifeq 4
3: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
4: StackMap locals:
StackMap stack:
return
5: StackMap locals:
StackMap stack: java.lang.InterruptedException
pop
6: iconst_1
istore 2
7: goto 1
8: StackMap locals:
StackMap stack: java.lang.Throwable
astore 3
9: iload 2
ifeq 11
10: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
11: StackMap locals: java.lang.Throwable
StackMap stack:
aload 3
athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 queue Ljava/util/concurrent/BlockingQueue<TE;>;
0 12 1 element TE;
1 12 2 interrupted Z
Exception table:
from to target type
1 2 5 Class java.lang.InterruptedException
1 2 8 any
5 8 8 any
Signature: <E:Ljava/lang/Object;>(Ljava/util/concurrent/BlockingQueue<TE;>;TE;)V
RuntimeInvisibleAnnotations:
com.google.common.annotations.GwtIncompatible()
MethodParameters:
Name Flags
queue
element
public static void sleepUninterruptibly(java.time.Duration);
descriptor: (Ljava/time/Duration;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
invokestatic com.google.common.util.concurrent.Internal.toNanosSaturated:(Ljava/time/Duration;)J
getstatic java.util.concurrent.TimeUnit.NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invokestatic com.google.common.util.concurrent.Uninterruptibles.sleepUninterruptibly:(JLjava/util/concurrent/TimeUnit;)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 sleepFor Ljava/time/Duration;
RuntimeInvisibleAnnotations:
com.google.common.annotations.GwtIncompatible()
com.google.common.annotations.Beta()
MethodParameters:
Name Flags
sleepFor
public static void sleepUninterruptibly(long, java.util.concurrent.TimeUnit);
descriptor: (JLjava/util/concurrent/TimeUnit;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=9, args_size=2
start local 0 start local 2 0: iconst_0
istore 3
start local 3 1: aload 2
lload 0
invokevirtual java.util.concurrent.TimeUnit.toNanos:(J)J
lstore 4
start local 4 2: invokestatic java.lang.System.nanoTime:()J
lload 4
ladd
lstore 6
start local 6 3: StackMap locals: int long long
StackMap stack:
getstatic java.util.concurrent.TimeUnit.NANOSECONDS:Ljava/util/concurrent/TimeUnit;
lload 4
invokevirtual java.util.concurrent.TimeUnit.sleep:(J)V
4: iload 3
ifeq 6
5: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
6: StackMap locals:
StackMap stack:
return
7: StackMap locals:
StackMap stack: java.lang.InterruptedException
pop
8: iconst_1
istore 3
9: lload 6
invokestatic java.lang.System.nanoTime:()J
lsub
lstore 4
10: goto 3
end local 6 end local 4 11: StackMap locals: long java.util.concurrent.TimeUnit int
StackMap stack: java.lang.Throwable
astore 8
12: iload 3
ifeq 14
13: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
14: StackMap locals: long java.util.concurrent.TimeUnit int top top top top java.lang.Throwable
StackMap stack:
aload 8
athrow
end local 3 end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 sleepFor J
0 15 2 unit Ljava/util/concurrent/TimeUnit;
1 15 3 interrupted Z
2 11 4 remainingNanos J
3 11 6 end J
Exception table:
from to target type
3 4 7 Class java.lang.InterruptedException
1 4 11 any
7 11 11 any
RuntimeInvisibleAnnotations:
com.google.common.annotations.GwtIncompatible()
MethodParameters:
Name Flags
sleepFor
unit
public static boolean tryAcquireUninterruptibly(java.util.concurrent.Semaphore, java.time.Duration);
descriptor: (Ljava/util/concurrent/Semaphore;Ljava/time/Duration;)Z
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic com.google.common.util.concurrent.Internal.toNanosSaturated:(Ljava/time/Duration;)J
getstatic java.util.concurrent.TimeUnit.NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invokestatic com.google.common.util.concurrent.Uninterruptibles.tryAcquireUninterruptibly:(Ljava/util/concurrent/Semaphore;JLjava/util/concurrent/TimeUnit;)Z
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 semaphore Ljava/util/concurrent/Semaphore;
0 1 1 timeout Ljava/time/Duration;
RuntimeInvisibleAnnotations:
com.google.common.annotations.GwtIncompatible()
com.google.common.annotations.Beta()
MethodParameters:
Name Flags
semaphore
timeout
public static boolean tryAcquireUninterruptibly(java.util.concurrent.Semaphore, long, java.util.concurrent.TimeUnit);
descriptor: (Ljava/util/concurrent/Semaphore;JLjava/util/concurrent/TimeUnit;)Z
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=3
start local 0 start local 1 start local 3 0: aload 0
iconst_1
lload 1
aload 3
invokestatic com.google.common.util.concurrent.Uninterruptibles.tryAcquireUninterruptibly:(Ljava/util/concurrent/Semaphore;IJLjava/util/concurrent/TimeUnit;)Z
ireturn
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 semaphore Ljava/util/concurrent/Semaphore;
0 1 1 timeout J
0 1 3 unit Ljava/util/concurrent/TimeUnit;
RuntimeInvisibleAnnotations:
com.google.common.annotations.GwtIncompatible()
MethodParameters:
Name Flags
semaphore
timeout
unit
public static boolean tryAcquireUninterruptibly(java.util.concurrent.Semaphore, int, java.time.Duration);
descriptor: (Ljava/util/concurrent/Semaphore;ILjava/time/Duration;)Z
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
iload 1
aload 2
invokestatic com.google.common.util.concurrent.Internal.toNanosSaturated:(Ljava/time/Duration;)J
getstatic java.util.concurrent.TimeUnit.NANOSECONDS:Ljava/util/concurrent/TimeUnit;
1: invokestatic com.google.common.util.concurrent.Uninterruptibles.tryAcquireUninterruptibly:(Ljava/util/concurrent/Semaphore;IJLjava/util/concurrent/TimeUnit;)Z
ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 semaphore Ljava/util/concurrent/Semaphore;
0 2 1 permits I
0 2 2 timeout Ljava/time/Duration;
RuntimeInvisibleAnnotations:
com.google.common.annotations.GwtIncompatible()
com.google.common.annotations.Beta()
MethodParameters:
Name Flags
semaphore
permits
timeout
public static boolean tryAcquireUninterruptibly(java.util.concurrent.Semaphore, int, long, java.util.concurrent.TimeUnit);
descriptor: (Ljava/util/concurrent/Semaphore;IJLjava/util/concurrent/TimeUnit;)Z
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=12, args_size=4
start local 0 start local 1 start local 2 start local 4 0: iconst_0
istore 5
start local 5 1: aload 4
lload 2
invokevirtual java.util.concurrent.TimeUnit.toNanos:(J)J
lstore 6
start local 6 2: invokestatic java.lang.System.nanoTime:()J
lload 6
ladd
lstore 8
start local 8 3: StackMap locals: int long long
StackMap stack:
aload 0
iload 1
lload 6
getstatic java.util.concurrent.TimeUnit.NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invokevirtual java.util.concurrent.Semaphore.tryAcquire:(IJLjava/util/concurrent/TimeUnit;)Z
istore 11
4: iload 5
ifeq 6
5: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
6: StackMap locals: java.util.concurrent.Semaphore int long java.util.concurrent.TimeUnit int long long top int
StackMap stack:
iload 11
ireturn
7: StackMap locals: java.util.concurrent.Semaphore int long java.util.concurrent.TimeUnit int long long
StackMap stack: java.lang.InterruptedException
pop
8: iconst_1
istore 5
9: lload 8
invokestatic java.lang.System.nanoTime:()J
lsub
lstore 6
10: goto 3
end local 8 end local 6 11: StackMap locals: java.util.concurrent.Semaphore int long java.util.concurrent.TimeUnit int
StackMap stack: java.lang.Throwable
astore 10
12: iload 5
ifeq 14
13: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
14: StackMap locals: java.util.concurrent.Semaphore int long java.util.concurrent.TimeUnit int top top top top java.lang.Throwable
StackMap stack:
aload 10
athrow
end local 5 end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 semaphore Ljava/util/concurrent/Semaphore;
0 15 1 permits I
0 15 2 timeout J
0 15 4 unit Ljava/util/concurrent/TimeUnit;
1 15 5 interrupted Z
2 11 6 remainingNanos J
3 11 8 end J
Exception table:
from to target type
3 4 7 Class java.lang.InterruptedException
1 4 11 any
7 11 11 any
RuntimeInvisibleAnnotations:
com.google.common.annotations.GwtIncompatible()
MethodParameters:
Name Flags
semaphore
permits
timeout
unit
public static boolean tryLockUninterruptibly(java.util.concurrent.locks.Lock, java.time.Duration);
descriptor: (Ljava/util/concurrent/locks/Lock;Ljava/time/Duration;)Z
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic com.google.common.util.concurrent.Internal.toNanosSaturated:(Ljava/time/Duration;)J
getstatic java.util.concurrent.TimeUnit.NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invokestatic com.google.common.util.concurrent.Uninterruptibles.tryLockUninterruptibly:(Ljava/util/concurrent/locks/Lock;JLjava/util/concurrent/TimeUnit;)Z
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 lock Ljava/util/concurrent/locks/Lock;
0 1 1 timeout Ljava/time/Duration;
RuntimeInvisibleAnnotations:
com.google.common.annotations.GwtIncompatible()
com.google.common.annotations.Beta()
MethodParameters:
Name Flags
lock
timeout
public static boolean tryLockUninterruptibly(java.util.concurrent.locks.Lock, long, java.util.concurrent.TimeUnit);
descriptor: (Ljava/util/concurrent/locks/Lock;JLjava/util/concurrent/TimeUnit;)Z
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=11, args_size=3
start local 0 start local 1 start local 3 0: iconst_0
istore 4
start local 4 1: aload 3
lload 1
invokevirtual java.util.concurrent.TimeUnit.toNanos:(J)J
lstore 5
start local 5 2: invokestatic java.lang.System.nanoTime:()J
lload 5
ladd
lstore 7
start local 7 3: StackMap locals: int long long
StackMap stack:
aload 0
lload 5
getstatic java.util.concurrent.TimeUnit.NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invokeinterface java.util.concurrent.locks.Lock.tryLock:(JLjava/util/concurrent/TimeUnit;)Z
istore 10
4: iload 4
ifeq 6
5: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
6: StackMap locals: java.util.concurrent.locks.Lock long java.util.concurrent.TimeUnit int long long top int
StackMap stack:
iload 10
ireturn
7: StackMap locals: java.util.concurrent.locks.Lock long java.util.concurrent.TimeUnit int long long
StackMap stack: java.lang.InterruptedException
pop
8: iconst_1
istore 4
9: lload 7
invokestatic java.lang.System.nanoTime:()J
lsub
lstore 5
10: goto 3
end local 7 end local 5 11: StackMap locals: java.util.concurrent.locks.Lock long java.util.concurrent.TimeUnit int
StackMap stack: java.lang.Throwable
astore 9
12: iload 4
ifeq 14
13: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
14: StackMap locals: java.util.concurrent.locks.Lock long java.util.concurrent.TimeUnit int top top top top java.lang.Throwable
StackMap stack:
aload 9
athrow
end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 lock Ljava/util/concurrent/locks/Lock;
0 15 1 timeout J
0 15 3 unit Ljava/util/concurrent/TimeUnit;
1 15 4 interrupted Z
2 11 5 remainingNanos J
3 11 7 end J
Exception table:
from to target type
3 4 7 Class java.lang.InterruptedException
1 4 11 any
7 11 11 any
RuntimeInvisibleAnnotations:
com.google.common.annotations.GwtIncompatible()
MethodParameters:
Name Flags
lock
timeout
unit
public static void awaitTerminationUninterruptibly(java.util.concurrent.ExecutorService);
descriptor: (Ljava/util/concurrent/ExecutorService;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
ldc 9223372036854775807
getstatic java.util.concurrent.TimeUnit.NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invokestatic com.google.common.util.concurrent.Uninterruptibles.awaitTerminationUninterruptibly:(Ljava/util/concurrent/ExecutorService;JLjava/util/concurrent/TimeUnit;)Z
invokestatic com.google.common.base.Verify.verify:(Z)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 executor Ljava/util/concurrent/ExecutorService;
RuntimeInvisibleAnnotations:
com.google.common.annotations.Beta()
com.google.common.annotations.GwtIncompatible()
MethodParameters:
Name Flags
executor
public static boolean awaitTerminationUninterruptibly(java.util.concurrent.ExecutorService, java.time.Duration);
descriptor: (Ljava/util/concurrent/ExecutorService;Ljava/time/Duration;)Z
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic com.google.common.util.concurrent.Internal.toNanosSaturated:(Ljava/time/Duration;)J
getstatic java.util.concurrent.TimeUnit.NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invokestatic com.google.common.util.concurrent.Uninterruptibles.awaitTerminationUninterruptibly:(Ljava/util/concurrent/ExecutorService;JLjava/util/concurrent/TimeUnit;)Z
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 executor Ljava/util/concurrent/ExecutorService;
0 1 1 timeout Ljava/time/Duration;
RuntimeInvisibleAnnotations:
com.google.common.annotations.Beta()
com.google.common.annotations.GwtIncompatible()
MethodParameters:
Name Flags
executor
timeout
public static boolean awaitTerminationUninterruptibly(java.util.concurrent.ExecutorService, long, java.util.concurrent.TimeUnit);
descriptor: (Ljava/util/concurrent/ExecutorService;JLjava/util/concurrent/TimeUnit;)Z
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=11, args_size=3
start local 0 start local 1 start local 3 0: iconst_0
istore 4
start local 4 1: aload 3
lload 1
invokevirtual java.util.concurrent.TimeUnit.toNanos:(J)J
lstore 5
start local 5 2: invokestatic java.lang.System.nanoTime:()J
lload 5
ladd
lstore 7
start local 7 3: StackMap locals: int long long
StackMap stack:
aload 0
lload 5
getstatic java.util.concurrent.TimeUnit.NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invokeinterface java.util.concurrent.ExecutorService.awaitTermination:(JLjava/util/concurrent/TimeUnit;)Z
istore 10
4: iload 4
ifeq 6
5: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
6: StackMap locals: java.util.concurrent.ExecutorService long java.util.concurrent.TimeUnit int long long top int
StackMap stack:
iload 10
ireturn
7: StackMap locals: java.util.concurrent.ExecutorService long java.util.concurrent.TimeUnit int long long
StackMap stack: java.lang.InterruptedException
pop
8: iconst_1
istore 4
9: lload 7
invokestatic java.lang.System.nanoTime:()J
lsub
lstore 5
10: goto 3
end local 7 end local 5 11: StackMap locals: java.util.concurrent.ExecutorService long java.util.concurrent.TimeUnit int
StackMap stack: java.lang.Throwable
astore 9
12: iload 4
ifeq 14
13: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
14: StackMap locals: java.util.concurrent.ExecutorService long java.util.concurrent.TimeUnit int top top top top java.lang.Throwable
StackMap stack:
aload 9
athrow
end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 executor Ljava/util/concurrent/ExecutorService;
0 15 1 timeout J
0 15 3 unit Ljava/util/concurrent/TimeUnit;
1 15 4 interrupted Z
2 11 5 remainingNanos J
3 11 7 end J
Exception table:
from to target type
3 4 7 Class java.lang.InterruptedException
1 4 11 any
7 11 11 any
RuntimeInvisibleAnnotations:
com.google.common.annotations.Beta()
com.google.common.annotations.GwtIncompatible()
MethodParameters:
Name Flags
executor
timeout
unit
private void <init>();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokespecial java.lang.Object.<init>:()V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/google/common/util/concurrent/Uninterruptibles;
}
SourceFile: "Uninterruptibles.java"
RuntimeInvisibleAnnotations:
com.google.common.annotations.GwtCompatible(emulated = true)