/guava/guava/src/com/google/common/util/concurrent/Futures.java
private volatile int delegateIndex = null ;
private volatile int delegateIndex = 0;
} private static final class InCompletionOrderState<T extends @Nullable Object> { private boolean wasCancelled = false; private boolean shouldInterrupt = true; private final AtomicInteger incompleteOutputCount; private final @Nullable ListenableFuture<? extends T>[] inputFutures; <extra_id_0> private InCompletionOrderState(ListenableFuture<? extends T>[] inputFutures) { this.inputFutures = inputFutures; incompleteOutputCount = new AtomicInteger(inputFutures.length); } private void recordOutputCancellation(boolean interruptIfRunning) { wasCancelled = true;