org.apache.storm.policy

Class WaitStrategyPark

java.lang.Object

org.apache.storm.policy.WaitStrategyPark

All Implemented Interfaces:

IWaitStrategy

public class WaitStrategyPark
extends Object
implements IWaitStrategy

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.storm.policy.IWaitStrategy

IWaitStrategy.WAIT_SITUATION

Constructor Summary

Constructors

Constructor and Description
WaitStrategyPark()
WaitStrategyPark(long microsec)

Method Summary

Modifier and Type	Method and Description
int	idle(int idleCounter) Implementations of this method should be thread-safe (preferably no side-effects and lock-free)
void	prepare(Map<String,Object> conf, IWaitStrategy.WAIT_SITUATION waitSituation)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.storm.policy.IWaitStrategy

createBackPressureWaitStrategy

Constructor Detail

WaitStrategyPark

public WaitStrategyPark()

WaitStrategyPark

public WaitStrategyPark(long microsec)

Method Detail

prepare

public void prepare(Map<String,Object> conf,
                    IWaitStrategy.WAIT_SITUATION waitSituation)

Specified by:

prepare in interface IWaitStrategy

idle

public int idle(int idleCounter)
         throws InterruptedException

Description copied from interface: IWaitStrategy

Implementations of this method should be thread-safe (preferably no side-effects and lock-free)

Supports static or dynamic backoff. Dynamic backoff relies on idleCounter to estimate how long caller has been idling.

   int idleCounter = 0;  int consumeCount = consumeFromQ();  while (consumeCount==0) {  idleCounter = strategy.idle(idleCounter);  consumeCount = consumeFromQ();  }  

Specified by:

idle in interface IWaitStrategy

Parameters:

idleCounter - managed by the idle method until reset

Returns:

new counter value to be used on subsequent idle cycle

Throws:

InterruptedException