public class ParkWaitStrategy extends Object implements com.lmax.disruptor.WaitStrategy
Constructor and Description |
---|
ParkWaitStrategy() |
ParkWaitStrategy(long parkFor) |
Modifier and Type | Method and Description |
---|---|
void |
signalAllWhenBlocking() |
long |
waitFor(long sequence,
com.lmax.disruptor.Sequence cursor,
com.lmax.disruptor.Sequence dependentSequence,
com.lmax.disruptor.SequenceBarrier barrier) |
public ParkWaitStrategy()
public ParkWaitStrategy(long parkFor)
public long waitFor(long sequence, com.lmax.disruptor.Sequence cursor, com.lmax.disruptor.Sequence dependentSequence, com.lmax.disruptor.SequenceBarrier barrier) throws com.lmax.disruptor.AlertException, InterruptedException, com.lmax.disruptor.TimeoutException
waitFor
in interface com.lmax.disruptor.WaitStrategy
com.lmax.disruptor.AlertException
InterruptedException
com.lmax.disruptor.TimeoutException
public void signalAllWhenBlocking()
signalAllWhenBlocking
in interface com.lmax.disruptor.WaitStrategy
Copyright © 2017. All rights reserved.