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 Summary

Fields

Modifier and Type	Field	Description
private final CountDownLatch	exit
private final int	number
private static final AtomicInteger	shows

Constructor Summary

Constructors

Modifier	Constructor	Description
private	Plateau()

Method Summary

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, 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(Object[] train, ZContext chef, ZMQ.Socket mic)
private void	showMustGoOn(ZContext chef, ZStar.Set set, ZMQ.Socket phone, ZStar.Fortune fortune, Object... bags)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

shows

private static final AtomicInteger shows

number

private final int number

exit

private final CountDownLatch exit

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.