public final class com.lmax.disruptor.PhasedBackoffWaitStrategy implements com.lmax.disruptor.WaitStrategy
minor version: 0
major version: 59
flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
this_class: com.lmax.disruptor.PhasedBackoffWaitStrategy
super_class: java.lang.Object
{
private static final int SPIN_TRIES;
descriptor: I
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: 10000
private final long spinTimeoutNanos;
descriptor: J
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final long yieldTimeoutNanos;
descriptor: J
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final com.lmax.disruptor.WaitStrategy fallbackStrategy;
descriptor: Lcom/lmax/disruptor/WaitStrategy;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
public void <init>(long, long, java.util.concurrent.TimeUnit, com.lmax.disruptor.WaitStrategy);
descriptor: (JJLjava/util/concurrent/TimeUnit;Lcom/lmax/disruptor/WaitStrategy;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=7, args_size=5
start local 0 start local 1 start local 3 start local 5 start local 6 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 5
lload 1
invokevirtual java.util.concurrent.TimeUnit.toNanos:(J)J
putfield com.lmax.disruptor.PhasedBackoffWaitStrategy.spinTimeoutNanos:J
2: aload 0
aload 0
getfield com.lmax.disruptor.PhasedBackoffWaitStrategy.spinTimeoutNanos:J
aload 5
lload 3
invokevirtual java.util.concurrent.TimeUnit.toNanos:(J)J
ladd
putfield com.lmax.disruptor.PhasedBackoffWaitStrategy.yieldTimeoutNanos:J
3: aload 0
aload 6
putfield com.lmax.disruptor.PhasedBackoffWaitStrategy.fallbackStrategy:Lcom/lmax/disruptor/WaitStrategy;
4: return
end local 6 end local 5 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lcom/lmax/disruptor/PhasedBackoffWaitStrategy;
0 5 1 spinTimeout J
0 5 3 yieldTimeout J
0 5 5 units Ljava/util/concurrent/TimeUnit;
0 5 6 fallbackStrategy Lcom/lmax/disruptor/WaitStrategy;
MethodParameters:
Name Flags
spinTimeout
yieldTimeout
units
fallbackStrategy
public static com.lmax.disruptor.PhasedBackoffWaitStrategy withLock(long, long, java.util.concurrent.TimeUnit);
descriptor: (JJLjava/util/concurrent/TimeUnit;)Lcom/lmax/disruptor/PhasedBackoffWaitStrategy;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=9, locals=5, args_size=3
start local 0 start local 2 start local 4 0: new com.lmax.disruptor.PhasedBackoffWaitStrategy
dup
1: lload 0
lload 2
2: aload 4
new com.lmax.disruptor.BlockingWaitStrategy
dup
invokespecial com.lmax.disruptor.BlockingWaitStrategy.<init>:()V
3: invokespecial com.lmax.disruptor.PhasedBackoffWaitStrategy.<init>:(JJLjava/util/concurrent/TimeUnit;Lcom/lmax/disruptor/WaitStrategy;)V
areturn
end local 4 end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 spinTimeout J
0 4 2 yieldTimeout J
0 4 4 units Ljava/util/concurrent/TimeUnit;
MethodParameters:
Name Flags
spinTimeout
yieldTimeout
units
public static com.lmax.disruptor.PhasedBackoffWaitStrategy withLiteLock(long, long, java.util.concurrent.TimeUnit);
descriptor: (JJLjava/util/concurrent/TimeUnit;)Lcom/lmax/disruptor/PhasedBackoffWaitStrategy;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=9, locals=5, args_size=3
start local 0 start local 2 start local 4 0: new com.lmax.disruptor.PhasedBackoffWaitStrategy
dup
1: lload 0
lload 2
2: aload 4
new com.lmax.disruptor.LiteBlockingWaitStrategy
dup
invokespecial com.lmax.disruptor.LiteBlockingWaitStrategy.<init>:()V
3: invokespecial com.lmax.disruptor.PhasedBackoffWaitStrategy.<init>:(JJLjava/util/concurrent/TimeUnit;Lcom/lmax/disruptor/WaitStrategy;)V
areturn
end local 4 end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 spinTimeout J
0 4 2 yieldTimeout J
0 4 4 units Ljava/util/concurrent/TimeUnit;
MethodParameters:
Name Flags
spinTimeout
yieldTimeout
units
public static com.lmax.disruptor.PhasedBackoffWaitStrategy withSleep(long, long, java.util.concurrent.TimeUnit);
descriptor: (JJLjava/util/concurrent/TimeUnit;)Lcom/lmax/disruptor/PhasedBackoffWaitStrategy;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=10, locals=5, args_size=3
start local 0 start local 2 start local 4 0: new com.lmax.disruptor.PhasedBackoffWaitStrategy
dup
1: lload 0
lload 2
2: aload 4
new com.lmax.disruptor.SleepingWaitStrategy
dup
iconst_0
invokespecial com.lmax.disruptor.SleepingWaitStrategy.<init>:(I)V
3: invokespecial com.lmax.disruptor.PhasedBackoffWaitStrategy.<init>:(JJLjava/util/concurrent/TimeUnit;Lcom/lmax/disruptor/WaitStrategy;)V
areturn
end local 4 end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 spinTimeout J
0 4 2 yieldTimeout J
0 4 4 units Ljava/util/concurrent/TimeUnit;
MethodParameters:
Name Flags
spinTimeout
yieldTimeout
units
public long waitFor(long, com.lmax.disruptor.Sequence, com.lmax.disruptor.Sequence, com.lmax.disruptor.SequenceBarrier);
descriptor: (JLcom/lmax/disruptor/Sequence;Lcom/lmax/disruptor/Sequence;Lcom/lmax/disruptor/SequenceBarrier;)J
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=13, args_size=5
start local 0 start local 1 start local 3 start local 4 start local 5 0: lconst_0
lstore 8
start local 8 1: sipush 10000
istore 10
start local 10 2: StackMap locals: com.lmax.disruptor.PhasedBackoffWaitStrategy long com.lmax.disruptor.Sequence com.lmax.disruptor.Sequence com.lmax.disruptor.SequenceBarrier top top long int
StackMap stack:
aload 4
invokevirtual com.lmax.disruptor.Sequence.get:()J
dup2
lstore 6
start local 6 3: lload 1
lcmp
iflt 5
4: lload 6
lreturn
5: StackMap locals: com.lmax.disruptor.PhasedBackoffWaitStrategy long com.lmax.disruptor.Sequence com.lmax.disruptor.Sequence com.lmax.disruptor.SequenceBarrier long long int
StackMap stack:
iinc 10 -1
iload 10
ifne 2
6: lconst_0
lload 8
lcmp
ifne 9
7: invokestatic java.lang.System.nanoTime:()J
lstore 8
8: goto 14
9: StackMap locals:
StackMap stack:
invokestatic java.lang.System.nanoTime:()J
lload 8
lsub
lstore 11
start local 11 10: lload 11
aload 0
getfield com.lmax.disruptor.PhasedBackoffWaitStrategy.yieldTimeoutNanos:J
lcmp
ifle 12
11: aload 0
getfield com.lmax.disruptor.PhasedBackoffWaitStrategy.fallbackStrategy:Lcom/lmax/disruptor/WaitStrategy;
lload 1
aload 3
aload 4
aload 5
invokeinterface com.lmax.disruptor.WaitStrategy.waitFor:(JLcom/lmax/disruptor/Sequence;Lcom/lmax/disruptor/Sequence;Lcom/lmax/disruptor/SequenceBarrier;)J
lreturn
12: StackMap locals: long
StackMap stack:
lload 11
aload 0
getfield com.lmax.disruptor.PhasedBackoffWaitStrategy.spinTimeoutNanos:J
lcmp
ifle 14
13: invokestatic java.lang.Thread.yield:()V
end local 11 14: StackMap locals:
StackMap stack:
sipush 10000
istore 10
15: goto 2
end local 10 end local 8 end local 6 end local 5 end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lcom/lmax/disruptor/PhasedBackoffWaitStrategy;
0 16 1 sequence J
0 16 3 cursor Lcom/lmax/disruptor/Sequence;
0 16 4 dependentSequence Lcom/lmax/disruptor/Sequence;
0 16 5 barrier Lcom/lmax/disruptor/SequenceBarrier;
3 16 6 availableSequence J
1 16 8 startTime J
2 16 10 counter I
10 14 11 timeDelta J
Exceptions:
throws com.lmax.disruptor.AlertException, java.lang.InterruptedException, com.lmax.disruptor.TimeoutException
MethodParameters:
Name Flags
sequence
cursor
dependentSequence
barrier
public void signalAllWhenBlocking();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield com.lmax.disruptor.PhasedBackoffWaitStrategy.fallbackStrategy:Lcom/lmax/disruptor/WaitStrategy;
invokeinterface com.lmax.disruptor.WaitStrategy.signalAllWhenBlocking:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/lmax/disruptor/PhasedBackoffWaitStrategy;
}
SourceFile: "PhasedBackoffWaitStrategy.java"