private static final class Futures.InCompletionOrderState<T>
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private int |
delegateIndex |
private java.util.concurrent.atomic.AtomicInteger |
incompleteOutputCount |
private ListenableFuture<? extends T>[] |
inputFutures |
private boolean |
shouldInterrupt |
private boolean |
wasCancelled |
Modifier | Constructor and Description |
---|---|
private |
InCompletionOrderState(ListenableFuture<? extends T>[] inputFutures) |
Modifier and Type | Method and Description |
---|---|
private void |
recordCompletion() |
private void |
recordInputCompletion(ImmutableList<AbstractFuture<T>> delegates,
int inputFutureIndex) |
private void |
recordOutputCancellation(boolean interruptIfRunning) |
private boolean wasCancelled
private boolean shouldInterrupt
private final java.util.concurrent.atomic.AtomicInteger incompleteOutputCount
private final ListenableFuture<? extends T>[] inputFutures
private volatile int delegateIndex
private InCompletionOrderState(ListenableFuture<? extends T>[] inputFutures)
private void recordOutputCancellation(boolean interruptIfRunning)
private void recordInputCompletion(ImmutableList<AbstractFuture<T>> delegates, int inputFutureIndex)
private void recordCompletion()