Package | Description |
---|---|
com.google.common.util.concurrent |
Concurrency utilities.
|
com.google.common.util.concurrent.testing |
Modifier and Type | Class and Description |
---|---|
(package private) class |
AbstractCatchingFuture<V,X extends java.lang.Throwable,F,T>
Implementations of
Futures.catching* . |
private static class |
AbstractCatchingFuture.AsyncCatchingFuture<V,X extends java.lang.Throwable>
|
private static class |
AbstractCatchingFuture.CatchingFuture<V,X extends java.lang.Throwable>
|
(package private) static class |
AbstractFuture.TrustedFuture<V>
A less abstract subclass of AbstractFuture.
|
(package private) class |
AbstractTransformFuture<I,O,F,T>
Implementations of
Futures.transform* . |
private static class |
AbstractTransformFuture.AsyncTransformFuture<I,O>
|
private static class |
AbstractTransformFuture.TransformFuture<I,O>
|
(package private) class |
AggregateFuture<InputT,OutputT>
A future made up of a collection of sub-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.
|
private static class |
Futures.NonCancellationPropagatingFuture<V>
A wrapped future that does not propagate cancellation to its delegate.
|
(package private) static class |
ImmediateFuture.ImmediateCancelledFuture<V> |
(package private) static class |
ImmediateFuture.ImmediateFailedFuture<V> |
private static class |
MoreExecutors.ScheduledListeningDecorator.NeverSuccessfulListenableFutureTask |
class |
SettableFuture<V>
A
ListenableFuture whose result can be set by a SettableFuture.set(Object) , SettableFuture.setException(Throwable) or SettableFuture.setFuture(ListenableFuture) call. |
(package private) class |
TimeoutFuture<V>
Implementation of
Futures#withTimeout . |
(package private) class |
TrustedListenableFutureTask<V>
A
RunnableFuture that also implements the ListenableFuture interface. |
Modifier and Type | Field and Description |
---|---|
(package private) AbstractFuture<V> |
AbstractFuture.SetFuture.owner |
Modifier and Type | Field and Description |
---|---|
(package private) java.util.concurrent.atomic.AtomicReferenceFieldUpdater<AbstractFuture,AbstractFuture.Listener> |
AbstractFuture.SafeAtomicHelper.listenersUpdater |
(package private) java.util.concurrent.atomic.AtomicReferenceFieldUpdater<AbstractFuture,java.lang.Object> |
AbstractFuture.SafeAtomicHelper.valueUpdater |
(package private) java.util.concurrent.atomic.AtomicReferenceFieldUpdater<AbstractFuture,AbstractFuture.Waiter> |
AbstractFuture.SafeAtomicHelper.waitersUpdater |
Modifier and Type | Method and Description |
---|---|
(package private) abstract boolean |
AbstractFuture.AtomicHelper.casListeners(AbstractFuture<?> future,
AbstractFuture.Listener expect,
AbstractFuture.Listener update)
Performs a CAS operation on the
listeners field. |
(package private) boolean |
AbstractFuture.UnsafeAtomicHelper.casListeners(AbstractFuture<?> future,
AbstractFuture.Listener expect,
AbstractFuture.Listener update)
Performs a CAS operation on the
listeners field. |
(package private) boolean |
AbstractFuture.SafeAtomicHelper.casListeners(AbstractFuture<?> future,
AbstractFuture.Listener expect,
AbstractFuture.Listener update) |
(package private) boolean |
AbstractFuture.SynchronizedHelper.casListeners(AbstractFuture<?> future,
AbstractFuture.Listener expect,
AbstractFuture.Listener update) |
(package private) abstract boolean |
AbstractFuture.AtomicHelper.casValue(AbstractFuture<?> future,
java.lang.Object expect,
java.lang.Object update)
Performs a CAS operation on the
value field. |
(package private) boolean |
AbstractFuture.UnsafeAtomicHelper.casValue(AbstractFuture<?> future,
java.lang.Object expect,
java.lang.Object update)
Performs a CAS operation on the
value field. |
(package private) boolean |
AbstractFuture.SafeAtomicHelper.casValue(AbstractFuture<?> future,
java.lang.Object expect,
java.lang.Object update) |
(package private) boolean |
AbstractFuture.SynchronizedHelper.casValue(AbstractFuture<?> future,
java.lang.Object expect,
java.lang.Object update) |
(package private) abstract boolean |
AbstractFuture.AtomicHelper.casWaiters(AbstractFuture<?> future,
AbstractFuture.Waiter expect,
AbstractFuture.Waiter update)
Performs a CAS operation on the
waiters field. |
(package private) boolean |
AbstractFuture.UnsafeAtomicHelper.casWaiters(AbstractFuture<?> future,
AbstractFuture.Waiter expect,
AbstractFuture.Waiter update)
Performs a CAS operation on the
waiters field. |
(package private) boolean |
AbstractFuture.SafeAtomicHelper.casWaiters(AbstractFuture<?> future,
AbstractFuture.Waiter expect,
AbstractFuture.Waiter update) |
(package private) boolean |
AbstractFuture.SynchronizedHelper.casWaiters(AbstractFuture<?> future,
AbstractFuture.Waiter expect,
AbstractFuture.Waiter update) |
private static void |
AbstractFuture.complete(AbstractFuture<?> future)
Unblocks all threads and runs all listeners.
|
(package private) static java.util.concurrent.Executor |
MoreExecutors.rejectionPropagatingExecutor(java.util.concurrent.Executor delegate,
AbstractFuture<?> future)
Returns an Executor that will propagate
RejectedExecutionException from the delegate
executor to the given future . |
Constructor and Description |
---|
SetFuture(AbstractFuture<V> owner,
ListenableFuture<? extends V> future) |
Constructor and Description |
---|
SafeAtomicHelper(java.util.concurrent.atomic.AtomicReferenceFieldUpdater<AbstractFuture.Waiter,java.lang.Thread> waiterThreadUpdater,
java.util.concurrent.atomic.AtomicReferenceFieldUpdater<AbstractFuture.Waiter,AbstractFuture.Waiter> waiterNextUpdater,
java.util.concurrent.atomic.AtomicReferenceFieldUpdater<AbstractFuture,AbstractFuture.Waiter> waitersUpdater,
java.util.concurrent.atomic.AtomicReferenceFieldUpdater<AbstractFuture,AbstractFuture.Listener> listenersUpdater,
java.util.concurrent.atomic.AtomicReferenceFieldUpdater<AbstractFuture,java.lang.Object> valueUpdater) |
SafeAtomicHelper(java.util.concurrent.atomic.AtomicReferenceFieldUpdater<AbstractFuture.Waiter,java.lang.Thread> waiterThreadUpdater,
java.util.concurrent.atomic.AtomicReferenceFieldUpdater<AbstractFuture.Waiter,AbstractFuture.Waiter> waiterNextUpdater,
java.util.concurrent.atomic.AtomicReferenceFieldUpdater<AbstractFuture,AbstractFuture.Waiter> waitersUpdater,
java.util.concurrent.atomic.AtomicReferenceFieldUpdater<AbstractFuture,AbstractFuture.Listener> listenersUpdater,
java.util.concurrent.atomic.AtomicReferenceFieldUpdater<AbstractFuture,java.lang.Object> valueUpdater) |
SafeAtomicHelper(java.util.concurrent.atomic.AtomicReferenceFieldUpdater<AbstractFuture.Waiter,java.lang.Thread> waiterThreadUpdater,
java.util.concurrent.atomic.AtomicReferenceFieldUpdater<AbstractFuture.Waiter,AbstractFuture.Waiter> waiterNextUpdater,
java.util.concurrent.atomic.AtomicReferenceFieldUpdater<AbstractFuture,AbstractFuture.Waiter> waitersUpdater,
java.util.concurrent.atomic.AtomicReferenceFieldUpdater<AbstractFuture,AbstractFuture.Listener> listenersUpdater,
java.util.concurrent.atomic.AtomicReferenceFieldUpdater<AbstractFuture,java.lang.Object> valueUpdater) |
Modifier and Type | Class and Description |
---|---|
private static class |
TestingExecutors.NoOpScheduledExecutorService.NeverScheduledFuture<V> |