com.google.common.util.concurrent

Class AggregateFutureState

java.lang.Object

com.google.common.util.concurrent.AggregateFutureState

Direct Known Subclasses:

AggregateFuture.RunningState

@GwtCompatible(emulated=true)
abstract class AggregateFutureState
extends java.lang.Object

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	AggregateFutureState.AtomicHelper
private static class	AggregateFutureState.SafeAtomicHelper
private static class	AggregateFutureState.SynchronizedAtomicHelper

Field Summary

Fields

Modifier and Type	Field and Description
private static AggregateFutureState.AtomicHelper	ATOMIC_HELPER
private static java.util.logging.Logger	log
private int	remaining
private java.util.Set<java.lang.Throwable>	seenExceptions

Constructor Summary

Constructors

Constructor and Description
AggregateFutureState(int remainingFutures)

Method Summary

Modifier and Type	Method and Description
(package private) abstract void	addInitialException(java.util.Set<java.lang.Throwable> seen) Populates seen with the exception that was passed to setException.
(package private) int	decrementRemainingAndGet()
(package private) java.util.Set<java.lang.Throwable>	getOrInitSeenExceptions()

Methods inherited from class java.lang.Object

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

Field Detail

seenExceptions

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

remaining

private volatile int remaining

ATOMIC_HELPER

private static final AggregateFutureState.AtomicHelper ATOMIC_HELPER

log

private static final java.util.logging.Logger log

Constructor Detail

AggregateFutureState

AggregateFutureState(int remainingFutures)

Method Detail

getOrInitSeenExceptions

final java.util.Set<java.lang.Throwable> getOrInitSeenExceptions()

addInitialException

abstract void addInitialException(java.util.Set<java.lang.Throwable> seen)

Populates seen with the exception that was passed to setException.

decrementRemainingAndGet

final int decrementRemainingAndGet()