K
- public class FutureLateJoin<K extends BaseFuture> extends BaseFutureImpl<FutureLateJoin<K>> implements BaseFuture
BaseFuture.FutureType
completed, lock, reason, type
Constructor and Description |
---|
FutureLateJoin(int nrMaxFutures)
Create this future and set the minSuccess to the number of expected
futures.
|
FutureLateJoin(int nrMaxFutures,
int minSuccess)
Create this future.
|
Modifier and Type | Method and Description |
---|---|
boolean |
add(K future)
Add a future when ready.
|
List<K> |
getFuturesDone()
Returns the finished futures.
|
K |
getLastSuceessFuture() |
addCancellation, addListener, addListener, await, await, awaitListeners, awaitUninterruptibly, awaitUninterruptibly, cancel, getFailedReason, getType, isCompleted, isFailed, isSuccess, notifyListerenrs, removeListener, self, setCompletedAndNotify, setFailed, setFailed, setFailed, setFailed, setFailed
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addCancellation, addListener, addListener, await, await, awaitListeners, awaitUninterruptibly, awaitUninterruptibly, getFailedReason, getType, isCompleted, isFailed, isSuccess, removeListener, setFailed, setFailed, setFailed, setFailed, setFailed
cancel
public FutureLateJoin(int nrMaxFutures)
nrMaxFutures
- The number of expected futures.public FutureLateJoin(int nrMaxFutures, int minSuccess)
nrMaxFutures
- The number of expected futures.minSuccess
- The number of expected successful futures.public boolean add(K future)
future
- The future to be added.public List<K> getFuturesDone()
public K getLastSuceessFuture()
Copyright © 2013. All Rights Reserved.