Class Futures.InCompletionOrderState<T>
java.lang.Object
com.google.common.util.concurrent.Futures.InCompletionOrderState<T>
- Enclosing class:
Futures
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate int
private final AtomicInteger
private final ListenableFuture<? extends T>[]
private boolean
private boolean
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprivate
InCompletionOrderState
(ListenableFuture<? extends T>[] inputFutures) -
Method Summary
Modifier and TypeMethodDescriptionprivate void
private void
recordInputCompletion
(ImmutableList<AbstractFuture<T>> delegates, int inputFutureIndex) private void
recordOutputCancellation
(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()
-