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