reactor.core.dispatch.wait

Class ParkWaitStrategy

java.lang.Object

reactor.core.dispatch.wait.ParkWaitStrategy

All Implemented Interfaces:

com.lmax.disruptor.WaitStrategy

public class ParkWaitStrategy
extends Object
implements com.lmax.disruptor.WaitStrategy

Author:

Jon Brisbin

Constructor Summary

Constructors

Constructor and Description
ParkWaitStrategy()
ParkWaitStrategy(long parkFor)

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ParkWaitStrategy

public ParkWaitStrategy()

ParkWaitStrategy

public ParkWaitStrategy(long parkFor)

Method Detail

waitFor

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

Specified by:

waitFor in interface com.lmax.disruptor.WaitStrategy

Throws:

com.lmax.disruptor.AlertException

InterruptedException

com.lmax.disruptor.TimeoutException

signalAllWhenBlocking

public void signalAllWhenBlocking()

Specified by:

signalAllWhenBlocking in interface com.lmax.disruptor.WaitStrategy