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 java.lang.Object implements ZThread.IAttachedRunnable, ZStar.Exit
-
-
Constructor Summary
Constructors Modifier Constructor Description private
Plateau()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
await()
Causes the current thread to wait in blocking mode until the end of the remote operations, unless the thread is interrupted.boolean
await(long timeout, java.util.concurrent.TimeUnit unit)
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.void
awaitSilent()
Causes the current thread to wait in blocking mode until the end of the remote operations.boolean
isExited()
Checks in non-blocking mode, if the remote operations have ended.void
run(java.lang.Object[] train, ZContext chef, ZMQ.Socket mic)
private void
showMustGoOn(ZContext chef, ZStar.Set set, ZMQ.Socket phone, ZStar.Fortune fortune, java.lang.Object... bags)
-
-
-
Method Detail
-
run
public void run(java.lang.Object[] train, ZContext chef, ZMQ.Socket mic)
- Specified by:
run
in interfaceZThread.IAttachedRunnable
-
showMustGoOn
private void showMustGoOn(ZContext chef, ZStar.Set set, ZMQ.Socket phone, ZStar.Fortune fortune, java.lang.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 interfaceZStar.Exit
-
await
public void await() throws java.lang.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,
InterruptedException
is thrown and the current thread's interrupted status is cleared.- Specified by:
await
in interfaceZStar.Exit
- Throws:
java.lang.InterruptedException
- if the current thread is interrupted while waiting
-
await
public boolean await(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.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,
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 interfaceZStar.Exit
- Parameters:
timeout
- the maximum time to waitunit
- the time unit of thetimeout
argument- Returns:
true
if the remote operations ended andfalse
if the waiting time elapsed before the remote operations ended- Throws:
java.lang.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 interfaceZStar.Exit
- Returns:
- true if the runnable where the remote operations occurred if finished, otherwise false.
-
-