reactor.core.dispatch.wait

Class AgileWaitingStrategy

java.lang.Object

reactor.core.dispatch.wait.AgileWaitingStrategy

All Implemented Interfaces:

com.lmax.disruptor.WaitStrategy, WaitingMood

public final class AgileWaitingStrategy
extends Object
implements com.lmax.disruptor.WaitStrategy, WaitingMood

A pair of slow and fast wait strategies to dynamically adapt to a given application load

Since:

2.0

Author:

Stephane Maldini

Constructor Summary

Constructors

Constructor and Description
AgileWaitingStrategy()
AgileWaitingStrategy(com.lmax.disruptor.WaitStrategy slowWaitStrategy, com.lmax.disruptor.WaitStrategy fastWaitStrategy)

Method Summary

Modifier and Type	Method and Description
void	calm() Turn the mood into eco CPU demand mode to save resources from the underlying component.
com.lmax.disruptor.WaitStrategy	current()
void	nervous() Turn the mood into aggressive CPU demand mode to effectively give an an additional resources boost to the underlying component.
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

AgileWaitingStrategy

public AgileWaitingStrategy()

AgileWaitingStrategy

public AgileWaitingStrategy(com.lmax.disruptor.WaitStrategy slowWaitStrategy,
                            com.lmax.disruptor.WaitStrategy fastWaitStrategy)

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

nervous

public void nervous()

Description copied from interface: WaitingMood

Turn the mood into aggressive CPU demand mode to effectively give an an additional resources boost to the underlying component.

Specified by:

nervous in interface WaitingMood

calm

public void calm()

Description copied from interface: WaitingMood

Turn the mood into eco CPU demand mode to save resources from the underlying component.

Specified by:

calm in interface WaitingMood

current

public com.lmax.disruptor.WaitStrategy current()