程序包 | 说明 |
---|---|
com.fr.third.jgroups.protocols |
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
|
com.fr.third.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
限定符和类型 | 方法和说明 |
---|---|
protected void |
RSVP.Entry.block(long timeout) |
限定符和类型 | 方法和说明 |
---|---|
protected T |
Promise._getResultWithTimeout(long timeout)
Blocks until a result is available, or timeout milliseconds have elapsed.
|
T |
Promise.getResultWithTimeout(long timeout)
Blocks until a result is available, or timeout milliseconds have elapsed
|
T |
Promise.getResultWithTimeout(long timeout,
boolean reset) |
java.lang.Object |
Queue.peek(long timeout)
returns the first object on the queue, without removing it.
|
java.lang.Object |
Queue.remove(long timeout)
Removes 1 element from the head.
|
java.lang.Object |
Queue.removeWait(long timeout) |
boolean |
AckCollector.waitForAllAcks(long timeout) |
static void |
Util.waitUntilAllChannelsHaveSameSize(long timeout,
long interval,
Channel... channels)
Blocks until all channels have the same view
|