Package org.apache.beam.sdk.util

Interface Sleeper

  • public interface Sleeper
    Sleeper interface to use for requesting the current thread to sleep as specified in Thread.sleep(long).

    The default implementation can be accessed at DEFAULT. Primarily used for testing.

    Note: This interface is copied from Google API client library to avoid its dependency.

    • Field Summary

      Fields 
      Modifier and Type Field Description
      static Sleeper DEFAULT
      Provides the default implementation based on Thread.sleep(long).

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void sleep​(long millis)
      Causes the currently executing thread to sleep (temporarily cease execution) for the specified number of milliseconds as specified in Thread.sleep(long).

    • Field Detail

      • DEFAULT

        static final Sleeper DEFAULT
        Provides the default implementation based on Thread.sleep(long).

    • Method Detail

      • sleep

        void sleep​(long millis)
    throws java.lang.InterruptedException
        Causes the currently executing thread to sleep (temporarily cease execution) for the specified number of milliseconds as specified in Thread.sleep(long).
        Parameters:
        millis - length of time to sleep in milliseconds
        Throws:
        java.lang.InterruptedException - if any thread has interrupted the current thread