Package org.apache.storm.policy
Class WaitStrategyPark
java.lang.Object
org.apache.storm.policy.WaitStrategyPark
- All Implemented Interfaces:
IWaitStrategy
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.apache.storm.policy.IWaitStrategy
IWaitStrategy.WaitSituation
-
Constructor Summary
-
Method Summary
-
Constructor Details
-
WaitStrategyPark
public WaitStrategyPark() -
WaitStrategyPark
public WaitStrategyPark(long microsec)
-
-
Method Details
-
prepare
- Specified by:
prepare
in interfaceIWaitStrategy
-
idle
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 interfaceIWaitStrategy
- Parameters:
idleCounter
- managed by the idle method until reset- Returns:
- new counter value to be used on subsequent idle cycle
- Throws:
InterruptedException
-