K
- public class FutureForkJoin<K extends BaseFuture> extends BaseFutureImpl<FutureForkJoin<K>> implements BaseFuture
BaseFuture.FutureType
completed, lock, reason, type
Constructor and Description |
---|
FutureForkJoin(int nrFinishFuturesSuccess,
boolean cancelFuturesOnFinish,
K... forks)
Create a future fork join object
|
FutureForkJoin(K... forks)
Facade if we expect everything to return successfully
|
Modifier and Type | Method and Description |
---|---|
List<K> |
getCompleted()
Returns a list of evaluated futures.
|
String |
getFailedReason()
The default failed reason is Unknown.
|
K |
getLast()
Returns the last evaluated future.
|
int |
getSuccessCounter()
Returns the number of successful finished futures
|
addCancellation, addListener, addListener, await, await, awaitListeners, awaitUninterruptibly, awaitUninterruptibly, cancel, 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, getType, isCompleted, isFailed, isSuccess, removeListener, setFailed, setFailed, setFailed, setFailed, setFailed
cancel
public FutureForkJoin(K... forks)
forks
- The futurespublic FutureForkJoin(int nrFinishFuturesSuccess, boolean cancelFuturesOnFinish, K... forks)
nrFinishFuturesSuccess
- Is the number of futures that we expect to succeed.cancelFuturesOnFinish
- Tells use if we should cancel the remaining futures. For get()
it makes sense to cancel, for store() it does not.forks
- The future array, that may contain null futures.public String getFailedReason()
BaseFuture
getFailedReason
in interface BaseFuture
getFailedReason
in class BaseFutureImpl<FutureForkJoin<K extends BaseFuture>>
public K getLast()
public List<K> getCompleted()
getLast()
.public int getSuccessCounter()
Copyright © 2013. All Rights Reserved.