Package | Description |
---|---|
com.google.common.util.concurrent |
Concurrency utilities.
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
AggregateFuture<InputT,OutputT>
A future whose value is derived from a collection of input futures.
|
(package private) class |
CollectionFuture<V,C>
Aggregate future that collects (stores) results of each future.
|
(package private) static class |
CollectionFuture.ListFuture<V>
|
(package private) class |
CombinedFuture<V>
Aggregate future that computes its value by calling a callable.
|
Modifier and Type | Field and Description |
---|---|
(package private) java.util.concurrent.atomic.AtomicIntegerFieldUpdater<AggregateFutureState<?>> |
AggregateFutureState.SafeAtomicHelper.remainingCountUpdater |
(package private) java.util.concurrent.atomic.AtomicReferenceFieldUpdater<AggregateFutureState<?>,java.util.Set<java.lang.Throwable>> |
AggregateFutureState.SafeAtomicHelper.seenExceptionsUpdater |
Modifier and Type | Method and Description |
---|---|
(package private) abstract void |
AggregateFutureState.AtomicHelper.compareAndSetSeenExceptions(AggregateFutureState<?> state,
java.util.Set<java.lang.Throwable> expect,
java.util.Set<java.lang.Throwable> update)
Atomic compare-and-set of the
seenExceptions field. |
(package private) void |
AggregateFutureState.SafeAtomicHelper.compareAndSetSeenExceptions(AggregateFutureState<?> state,
java.util.Set<java.lang.Throwable> expect,
java.util.Set<java.lang.Throwable> update) |
(package private) void |
AggregateFutureState.SynchronizedAtomicHelper.compareAndSetSeenExceptions(AggregateFutureState<?> state,
java.util.Set<java.lang.Throwable> expect,
java.util.Set<java.lang.Throwable> update) |
(package private) abstract int |
AggregateFutureState.AtomicHelper.decrementAndGetRemainingCount(AggregateFutureState<?> state)
Atomic decrement-and-get of the
remaining field. |
(package private) int |
AggregateFutureState.SafeAtomicHelper.decrementAndGetRemainingCount(AggregateFutureState<?> state) |
(package private) int |
AggregateFutureState.SynchronizedAtomicHelper.decrementAndGetRemainingCount(AggregateFutureState<?> state) |