abstract class AggregateFutureState<OutputT> extends AbstractFuture.TrustedFuture<OutputT>
| Modifier and Type | Class and Description |
|---|---|
private static class |
AggregateFutureState.AtomicHelper |
private static class |
AggregateFutureState.SafeAtomicHelper |
private static class |
AggregateFutureState.SynchronizedAtomicHelper |
AbstractFuture.Trusted<V>, AbstractFuture.TrustedFuture<V>| Modifier and Type | Field and Description |
|---|---|
private static AggregateFutureState.AtomicHelper |
ATOMIC_HELPER |
private static java.util.logging.Logger |
log |
private int |
remaining |
private java.util.Set<java.lang.Throwable> |
seenExceptions |
GENERATE_CANCELLATION_CAUSES| Constructor and Description |
|---|
AggregateFutureState(int remainingFutures) |
| Modifier and Type | Method and Description |
|---|---|
(package private) abstract void |
addInitialException(java.util.Set<java.lang.Throwable> seen)
Populates
seen with the exception that was passed to setException. |
(package private) void |
clearSeenExceptions() |
(package private) int |
decrementRemainingAndGet() |
(package private) java.util.Set<java.lang.Throwable> |
getOrInitSeenExceptions() |
addListener, cancel, get, get, isCancelled, isDoneafterDone, interruptTask, maybePropagateCancellationTo, pendingToString, set, setException, setFuture, toString, tryInternalFastPathGetFailure, wasInterrupted@CheckForNull private volatile java.util.Set<java.lang.Throwable> seenExceptions
private volatile int remaining
private static final AggregateFutureState.AtomicHelper ATOMIC_HELPER
private static final java.util.logging.Logger log
final java.util.Set<java.lang.Throwable> getOrInitSeenExceptions()
abstract void addInitialException(java.util.Set<java.lang.Throwable> seen)
seen with the exception that was passed to setException.final int decrementRemainingAndGet()
final void clearSeenExceptions()