com.google.common.util.concurrent

Class Futures.CombinedFuture<V,C>

java.lang.Object

com.google.common.util.concurrent.AbstractFuture<C>

com.google.common.util.concurrent.Futures.CombinedFuture<V,C>

All Implemented Interfaces:

ListenableFuture<C>, java.util.concurrent.Future<C>

Enclosing class:

Futures

private static class Futures.CombinedFuture<V,C>
extends AbstractFuture<C>

Nested Class Summary

Nested classes/interfaces inherited from class com.google.common.util.concurrent.AbstractFuture

AbstractFuture.Sync<V>

Field Summary

Fields

Modifier and Type	Field and Description
(package private) boolean	allMustSucceed
(package private) Futures.FutureCombiner<V,C>	combiner
(package private) ImmutableCollection<? extends ListenableFuture<? extends V>>	futures
private static java.util.logging.Logger	logger
(package private) java.util.concurrent.atomic.AtomicInteger	remaining
(package private) java.util.Set<java.lang.Throwable>	seenExceptions
(package private) java.lang.Object	seenExceptionsLock
(package private) java.util.List<Optional<V>>	values

Constructor Summary

Constructors

Constructor and Description
CombinedFuture(ImmutableCollection<? extends ListenableFuture<? extends V>> futures, boolean allMustSucceed, java.util.concurrent.Executor listenerExecutor, Futures.FutureCombiner<V,C> combiner)

Method Summary

Modifier and Type	Method and Description
protected void	init(java.util.concurrent.Executor listenerExecutor) Must be called at the end of the constructor.
private void	setExceptionAndMaybeLog(java.lang.Throwable throwable) Fails this future with the given Throwable if allMustSucceed is true.
private void	setOneValue(int index, java.util.concurrent.Future<? extends V> future) Sets the value at the given index to that of the given future.

Methods inherited from class com.google.common.util.concurrent.AbstractFuture

addListener, cancel, cancellationExceptionWithCause, get, get, interruptTask, isCancelled, isDone, set, setException, wasInterrupted

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

logger

private static final java.util.logging.Logger logger

futures

ImmutableCollection<? extends ListenableFuture<? extends V>> futures

allMustSucceed

final boolean allMustSucceed

remaining

final java.util.concurrent.atomic.AtomicInteger remaining

combiner

Futures.FutureCombiner<V,C> combiner

values

java.util.List<Optional<V>> values

seenExceptionsLock

final java.lang.Object seenExceptionsLock

seenExceptions

java.util.Set<java.lang.Throwable> seenExceptions

Constructor Detail

CombinedFuture

CombinedFuture(ImmutableCollection<? extends ListenableFuture<? extends V>> futures,
               boolean allMustSucceed,
               java.util.concurrent.Executor listenerExecutor,
               Futures.FutureCombiner<V,C> combiner)

Method Detail

init

protected void init(java.util.concurrent.Executor listenerExecutor)

Must be called at the end of the constructor.

setExceptionAndMaybeLog

private void setExceptionAndMaybeLog(java.lang.Throwable throwable)

Fails this future with the given Throwable if allMustSucceed is true. Also, logs the throwable if it is an Error or if allMustSucceed is true, the throwable did not cause this future to fail, and it is the first time we've seen that particular Throwable.

setOneValue

private void setOneValue(int index,
                         java.util.concurrent.Future<? extends V> future)

Sets the value at the given index to that of the given future.