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, isDone
afterDone, 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()