Package org.zeromq

Class ZStar.Plateau

java.lang.Object
org.zeromq.ZStar.Plateau
All Implemented Interfaces:
ZStar.Exit, ZThread.IAttachedRunnable
Enclosing class:
ZStar

private static final class ZStar.Plateau extends Object implements ZThread.IAttachedRunnable, ZStar.Exit
  • Field Details

  • Constructor Details

    • Plateau

      private Plateau()
  • Method Details

    • run

      public void run(Object[] train, ZContext chef, ZMQ.Socket mic)
      Specified by:
      run in interface ZThread.IAttachedRunnable
    • showMustGoOn

      private void showMustGoOn(ZContext chef, ZStar.Set set, ZMQ.Socket phone, ZStar.Fortune fortune, Object... bags)
    • awaitSilent

      public void awaitSilent()
      Description copied from interface: ZStar.Exit
      Causes the current thread to wait in blocking mode until the end of the remote operations.
      Specified by:
      awaitSilent in interface ZStar.Exit
    • await

      public void await() throws InterruptedException
      Description copied from interface: ZStar.Exit
      Causes the current thread to wait in blocking mode until the end of the remote operations, unless the thread is interrupted.

      If the current thread:

      • has its interrupted status set on entry to this method; or
      • is interrupted while waiting,
      then InterruptedException is thrown and the current thread's interrupted status is cleared.
      Specified by:
      await in interface ZStar.Exit
      Throws:
      InterruptedException - if the current thread is interrupted while waiting
    • await

      public boolean await(long timeout, TimeUnit unit) throws InterruptedException
      Description copied from interface: ZStar.Exit
      Causes the current thread to wait in blocking mode until the end of the remote operations, unless the thread is interrupted, or the specified waiting time elapses.

      If the current thread:

      • has its interrupted status set on entry to this method; or
      • is interrupted while waiting,
      then InterruptedException is thrown and the current thread's interrupted status is cleared.

      If the specified waiting time elapses then the value false is returned. If the time is less than or equal to zero, the method will not wait at all.

      Specified by:
      await in interface ZStar.Exit
      Parameters:
      timeout - the maximum time to wait
      unit - the time unit of the timeout argument
      Returns:
      true if the remote operations ended and false if the waiting time elapsed before the remote operations ended
      Throws:
      InterruptedException - if the current thread is interrupted while waiting
    • isExited

      public boolean isExited()
      Description copied from interface: ZStar.Exit
      Checks in non-blocking mode, if the remote operations have ended.
      Specified by:
      isExited in interface ZStar.Exit
      Returns:
      true if the runnable where the remote operations occurred if finished, otherwise false.