Class Futures.InCompletionOrderState<T>
- java.lang.Object
-
- com.google.common.util.concurrent.Futures.InCompletionOrderState<T>
-
- Enclosing class:
- Futures
private static final class Futures.InCompletionOrderState<T> extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description private int
delegateIndex
private java.util.concurrent.atomic.AtomicInteger
incompleteOutputCount
private ListenableFuture<? extends T>[]
inputFutures
private boolean
shouldInterrupt
private boolean
wasCancelled
-
Constructor Summary
Constructors Modifier Constructor Description private
InCompletionOrderState(ListenableFuture<? extends T>[] inputFutures)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private void
recordCompletion()
private void
recordInputCompletion(ImmutableList<AbstractFuture<T>> delegates, int inputFutureIndex)
private void
recordOutputCancellation(boolean interruptIfRunning)
-
-
-
Field Detail
-
wasCancelled
private boolean wasCancelled
-
shouldInterrupt
private boolean shouldInterrupt
-
incompleteOutputCount
private final java.util.concurrent.atomic.AtomicInteger incompleteOutputCount
-
inputFutures
private final ListenableFuture<? extends T>[] inputFutures
-
delegateIndex
private volatile int delegateIndex
-
-
Constructor Detail
-
InCompletionOrderState
private InCompletionOrderState(ListenableFuture<? extends T>[] inputFutures)
-
-
Method Detail
-
recordOutputCancellation
private void recordOutputCancellation(boolean interruptIfRunning)
-
recordInputCompletion
private void recordInputCompletion(ImmutableList<AbstractFuture<T>> delegates, int inputFutureIndex)
-
recordCompletion
private void recordCompletion()
-
-