Class AggregateFutureState<OutputT>

All Implemented Interfaces:
AbstractFuture.Trusted<OutputT>, ListenableFuture<OutputT>, Future<OutputT>
Direct Known Subclasses:
AggregateFuture

abstract class AggregateFutureState<OutputT> extends AbstractFuture.TrustedFuture<OutputT>
A helper which does some thread-safe operations for aggregate futures, which must be implemented differently in GWT. Namely:
  • Lazily initializes a set of seen exceptions
  • Decrements a counter atomically
  • Field Details

  • Constructor Details

    • AggregateFutureState

      AggregateFutureState(int remainingFutures)
  • Method Details

    • getOrInitSeenExceptions

      final Set<Throwable> getOrInitSeenExceptions()
    • addInitialException

      abstract void addInitialException(Set<Throwable> seen)
      Populates seen with the exception that was passed to setException.
    • decrementRemainingAndGet

      final int decrementRemainingAndGet()
    • clearSeenExceptions

      final void clearSeenExceptions()