Class SleepingMillisIdleStrategy

java.lang.Object
org.agrona.concurrent.SleepingMillisIdleStrategy
All Implemented Interfaces:
IdleStrategy
public final class SleepingMillisIdleStrategy extends Object implements IdleStrategy
When idle this strategy is to sleep for a specified period time in milliseconds.

This class uses Thread.sleep(long) to idle.

  • Field Details

  • Constructor Details

    • SleepingMillisIdleStrategy

      public SleepingMillisIdleStrategy()
      Default constructor that uses DEFAULT_SLEEP_PERIOD_MS.

    • SleepingMillisIdleStrategy

      public SleepingMillisIdleStrategy(long sleepPeriodMs)
      Constructed a new strategy that will sleep for a given period when idle.
      Parameters:
      sleepPeriodMs - period in milliseconds for which the strategy will sleep when work count is 0.

  • Method Details

    • idle

      public void idle(int workCount)
      Perform current idle action (e.g. nothing/yield/sleep). This method signature expects users to call into it on every work 'cycle'. The implementations may use the indication "workCount > 0" to reset internal backoff state. This method works well with 'work' APIs which follow the following rules:
      • 'work' returns a value larger than 0 when some work has been done
      • 'work' returns 0 when no work has been done
      • 'work' may return error codes which are less than 0, but which amount to no work has been done

      Callers are expected to follow this pattern: 

      
while (isRunning)
{
    idleStrategy.idle(doWork());
}
      Specified by:
      idle in interface IdleStrategy
      Parameters:
      workCount - performed in last duty cycle.

    • idle

      public void idle()
      Perform current idle action (e.g. nothing/yield/sleep). To be used in conjunction with IdleStrategy.reset() to clear internal state when idle period is over (or before it begins). Callers are expected to follow this pattern: 
      
while (isRunning)
{
  if (!hasWork())
  {
    idleStrategy.reset();
    while (!hasWork())
    {
      if (!isRunning)
      {
        return;
      }
      idleStrategy.idle();
    }
  }
  doWork();
}
      Specified by:
      idle in interface IdleStrategy

    • reset

      public void reset()
      Reset the internal state in preparation for entering an idle state again.
      Specified by:
      reset in interface IdleStrategy

    • alias

      public String alias()
      Simple name by which the strategy can be identified.
      Specified by:
      alias in interface IdleStrategy
      Returns:
      simple name by which the strategy can be identified.

    • toString

      public String toString()
      Overrides:
      toString in class Object