Class Futures.InCompletionOrderState<T>
java.lang.Object
com.google.common.util.concurrent.Futures.InCompletionOrderState<T>
- Enclosing class:
Futures
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate intprivate final AtomicIntegerprivate final ListenableFuture<? extends T>[]private booleanprivate boolean -
Constructor Summary
ConstructorsModifierConstructorDescriptionprivateInCompletionOrderState(ListenableFuture<? extends T>[] inputFutures) -
Method Summary
Modifier and TypeMethodDescriptionprivate voidprivate voidrecordInputCompletion(ImmutableList<AbstractFuture<T>> delegates, int inputFutureIndex) private voidrecordOutputCancellation(boolean interruptIfRunning)
-
Field Details
-
wasCancelled
private boolean wasCancelled -
shouldInterrupt
private boolean shouldInterrupt -
incompleteOutputCount
-
inputFutures
-
delegateIndex
private volatile int delegateIndex
-
-
Constructor Details
-
InCompletionOrderState
-
-
Method Details
-
recordOutputCancellation
private void recordOutputCancellation(boolean interruptIfRunning) -
recordInputCompletion
private void recordInputCompletion(ImmutableList<AbstractFuture<T>> delegates, int inputFutureIndex) -
recordCompletion
private void recordCompletion()
-