Package com.google.common.util.concurrent

Class CollectionFuture.CollectionFutureRunningState

java.lang.Object

com.google.common.util.concurrent.AggregateFutureState

com.google.common.util.concurrent.AggregateFuture.RunningState

com.google.common.util.concurrent.CollectionFuture.CollectionFutureRunningState

All Implemented Interfaces:

java.lang.Runnable

Direct Known Subclasses:

CollectionFuture.ListFuture.ListFutureRunningState

Enclosing class:

CollectionFuture<V,C>

abstract class CollectionFuture.CollectionFutureRunningState
extends AggregateFuture.RunningState

Field Summary

Fields

Modifier and Type	Field	Description
private java.util.List<Optional<V>>	values

Constructor Summary

Constructors

Constructor	Description
CollectionFutureRunningState(ImmutableCollection<? extends ListenableFuture<? extends V>> futures, boolean allMustSucceed)

Method Summary

Modifier and Type	Method	Description
(package private) void	collectOneValue(boolean allMustSucceed, int index, V returnValue)	Called only if collectsValues is true.
(package private) abstract C	combine(java.util.List<Optional<V>> values)
(package private) void	handleAllCompleted()
(package private) void	releaseResourcesAfterFailure()	Listeners implicitly keep a reference to AggregateFuture.RunningState as they're inner classes, so we free resources here as well for the allMustSucceed=true case (i.e.

Methods inherited from class com.google.common.util.concurrent.AggregateFuture.RunningState

addInitialException, interruptTask, run

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

decrementRemainingAndGet, getOrInitSeenExceptions

Methods inherited from class java.lang.Object

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

Field Detail

values

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

Constructor Detail

CollectionFutureRunningState

CollectionFutureRunningState(ImmutableCollection<? extends ListenableFuture<? extends V>> futures,
                             boolean allMustSucceed)

Method Detail

collectOneValue

final void collectOneValue(boolean allMustSucceed,
                           int index,
                           V returnValue)

Description copied from class: AggregateFuture.RunningState

Called only if collectsValues is true.

If allMustSucceed is true, called as each future completes; otherwise, called for each future when all futures complete.

Specified by:

collectOneValue in class AggregateFuture.RunningState

handleAllCompleted

final void handleAllCompleted()

Specified by:

handleAllCompleted in class AggregateFuture.RunningState

releaseResourcesAfterFailure

void releaseResourcesAfterFailure()

Description copied from class: AggregateFuture.RunningState

Listeners implicitly keep a reference to AggregateFuture.RunningState as they're inner classes, so we free resources here as well for the allMustSucceed=true case (i.e. when a future fails, we immediately release resources we no longer need); additionally, the future will release its reference to AggregateFuture.RunningState, which should free all associated memory when all the futures complete and the listeners are released.

TODO(user): Write tests for memory retention

Overrides:

releaseResourcesAfterFailure in class AggregateFuture.RunningState

combine

abstract C combine(java.util.List<Optional<V>> values)