Uses of Annotation Interface
com.google.common.util.concurrent.ParametricNullness
Packages that use ParametricNullness
-
Uses of ParametricNullness in com.google.common.util.concurrent
Fields in com.google.common.util.concurrent with annotations of type ParametricNullnessModifier and TypeFieldDescription(package private) final V
CollectionFuture.Present.value
private final V
ImmediateFuture.value
Methods in com.google.common.util.concurrent with annotations of type ParametricNullnessModifier and TypeMethodDescriptionClosingFuture.ClosingFunction.apply
(ClosingFuture.DeferredCloser closer, T input) Applies this function to an input, or throws an exception if unable to do so.ClosingFuture.Combiner2.ClosingFunction2.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2) Applies this function to two inputs, or throws an exception if unable to do so.ClosingFuture.Combiner3.ClosingFunction3.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3) Applies this function to three inputs, or throws an exception if unable to do so.ClosingFuture.Combiner4.ClosingFunction4.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3, V4 value4) Applies this function to four inputs, or throws an exception if unable to do so.ClosingFuture.Combiner5.ClosingFunction5.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3, V4 value4, V5 value5) Applies this function to five inputs, or throws an exception if unable to do so.ClosingFuture.ClosingCallable.call
(ClosingFuture.DeferredCloser closer) Computes a result, or throws an exception if unable to do so.ClosingFuture.Combiner.CombiningCallable.call
(ClosingFuture.DeferredCloser closer, ClosingFuture.Peeker peeker) Computes a result, or throws an exception if unable to do so.private <V> V
ClosingFuture.Peeker.call
(ClosingFuture.Combiner.CombiningCallable<V> combiner, ClosingFuture.CloseableList closeables) <T> T
FakeTimeLimiter.callUninterruptiblyWithTimeout
(Callable<T> callable, long timeoutDuration, TimeUnit timeoutUnit) <T> T
SimpleTimeLimiter.callUninterruptiblyWithTimeout
(Callable<T> callable, long timeoutDuration, TimeUnit timeoutUnit) <T> T
TimeLimiter.callUninterruptiblyWithTimeout
(Callable<T> callable, long timeoutDuration, TimeUnit timeoutUnit) Invokes a specified Callable, timing out after the specified time limit.default <T> T
TimeLimiter.callUninterruptiblyWithTimeout
(Callable<T> callable, Duration timeout) Invokes a specified Callable, timing out after the specified time limit.<T> T
FakeTimeLimiter.callWithTimeout
(Callable<T> callable, long timeoutDuration, TimeUnit timeoutUnit) <T> T
SimpleTimeLimiter.callWithTimeout
(Callable<T> callable, long timeoutDuration, TimeUnit timeoutUnit) private <T> T
SimpleTimeLimiter.callWithTimeout
(Callable<T> callable, long timeoutDuration, TimeUnit timeoutUnit, boolean amInterruptible) <T> T
TimeLimiter.callWithTimeout
(Callable<T> callable, long timeoutDuration, TimeUnit timeoutUnit) Invokes a specified Callable, timing out after the specified time limit.default <T> T
TimeLimiter.callWithTimeout
(Callable<T> callable, Duration timeout) Invokes a specified Callable, timing out after the specified time limit.(package private) V
AbstractCatchingFuture.CatchingFuture.doFallback
(Function<? super X, ? extends V> fallback, X cause) (package private) abstract T
AbstractCatchingFuture.doFallback
(F fallback, X throwable) Template method for subtypes to actually run the fallback.(package private) abstract T
AbstractTransformFuture.doTransform
(F function, I result) Template method for subtypes to actually run the transform.(package private) O
AbstractTransformFuture.TransformFuture.doTransform
(Function<? super I, ? extends O> function, I input) <C extends Object & AutoCloseable>
CClosingFuture.DeferredCloser.eventuallyClose
(C closeable, Executor closingExecutor) Captures an object to be closed when aClosingFuture
pipeline is done.AbstractFuture.get()
final V
AbstractFuture.TrustedFuture.get()
final V
ClosingFuture.ValueAndCloser.get()
Returns the final value of the associatedClosingFuture
, or throws an exception asFuture.get()
would.final V
FluentFuture.TrustedFuture.get()
final V
ForwardingFluentFuture.get()
ForwardingFuture.get()
ImmediateFuture.get()
static <V,
X extends Exception>
VFutures.getChecked
(Future<V> future, Class<X> exceptionClass) Returns the result ofFuture.get()
, converting most exceptions to a new instance of the given checked exception type.static <V,
X extends Exception>
VFutures.getChecked
(Future<V> future, Class<X> exceptionClass, long timeout, TimeUnit unit) Returns the result ofFuture.get(long, TimeUnit)
, converting most exceptions to a new instance of the given checked exception type.static <V,
X extends Exception>
VFutures.getChecked
(Future<V> future, Class<X> exceptionClass, Duration timeout) Returns the result ofFuture.get(long, TimeUnit)
, converting most exceptions to a new instance of the given checked exception type.(package private) static <V,
X extends Exception>
VFuturesGetChecked.getChecked
(FuturesGetChecked.GetCheckedTypeValidator validator, Future<V> future, Class<X> exceptionClass) Implementation ofFutures.getChecked(Future, Class)
.(package private) static <V,
X extends Exception>
VFuturesGetChecked.getChecked
(Future<V> future, Class<X> exceptionClass) (package private) static <V,
X extends Exception>
VFuturesGetChecked.getChecked
(Future<V> future, Class<X> exceptionClass, long timeout, TimeUnit unit) Implementation ofFutures.getChecked(Future, Class, long, TimeUnit)
.final <D> D
ClosingFuture.Peeker.getDone
(ClosingFuture<D> closingFuture) Returns the value ofclosingFuture
.static <V> V
Returns the result of the inputFuture
, which must have already completed.private V
AbstractFuture.getDoneValue
(Object obj) Unboxesobj
.static <V> V
Futures.getUnchecked
(Future<V> future) Returns the result of callingFuture.get()
uninterruptibly on a task known not to throw a checked exception.private static <V> V
AbstractFuture.getUninterruptibly
(Future<V> future) An inlined private copy ofUninterruptibles.getUninterruptibly(java.util.concurrent.Future<V>)
used to break an internal dependency on other /util/concurrent classes.static <V> V
Uninterruptibles.getUninterruptibly
(Future<V> future) Invokesfuture.
get()
uninterruptibly.static <V> V
Uninterruptibles.getUninterruptibly
(Future<V> future, long timeout, TimeUnit unit) Invokesfuture.
get(timeout, unit)
uninterruptibly.static <V> V
Uninterruptibles.getUninterruptibly
(Future<V> future, Duration timeout) Invokesfuture.
get(timeout, unit)
uninterruptibly.(package private) static <T> T
MoreExecutors.invokeAnyImpl
(ListeningExecutorService executorService, Collection<? extends Callable<T>> tasks, boolean timed, long timeout, TimeUnit unit) An implementation ofExecutorService.invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>>)
forListeningExecutorService
implementations.(package private) static <T> T
MoreExecutors.invokeAnyImpl
(ListeningExecutorService executorService, Collection<? extends Callable<T>> tasks, boolean timed, Duration timeout) An implementation ofExecutorService.invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>>)
forListeningExecutorService
implementations.(package private) V
CombinedFuture.CallableInterruptibleTask.runInterruptibly()
(package private) abstract T
InterruptibleTask.runInterruptibly()
Do interruptible work here - do not complete Futures here, as their listeners could be interrupted.(package private) V
TrustedListenableFutureTask.TrustedFutureInterruptibleTask.runInterruptibly()
(package private) static <T> T
NullnessCasts.uncheckedCastNullableTToT
(T t) Accepts a@Nullable T
and returns a plainT
, without performing any check that that conversion is safe.(package private) static <T> T
NullnessCasts.uncheckedNull()
Returnsnull
cast to any type.Method parameters in com.google.common.util.concurrent with annotations of type ParametricNullnessModifier and TypeMethodDescription(package private) final void
CombinedFuture.CombinedFutureInterruptibleTask.afterRanInterruptiblySuccess
(T result) (package private) abstract void
InterruptibleTask.afterRanInterruptiblySuccess
(T result) Any interruption that happens as a result of calling interruptTask will arrive before this method is called.(package private) void
TrustedListenableFutureTask.TrustedFutureInterruptibleTask.afterRanInterruptiblySuccess
(V result) Returns an outputFuture
to use in place of the giveninput
.ClosingFuture.AsyncClosingFunction.apply
(ClosingFuture.DeferredCloser closer, T input) Applies this function to an input, or throws an exception if unable to do so.ClosingFuture.ClosingFunction.apply
(ClosingFuture.DeferredCloser closer, T input) Applies this function to an input, or throws an exception if unable to do so.ClosingFuture.Combiner2.AsyncClosingFunction2.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2) Applies this function to two inputs, or throws an exception if unable to do so.ClosingFuture.Combiner2.AsyncClosingFunction2.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2) Applies this function to two inputs, or throws an exception if unable to do so.ClosingFuture.Combiner2.ClosingFunction2.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2) Applies this function to two inputs, or throws an exception if unable to do so.ClosingFuture.Combiner2.ClosingFunction2.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2) Applies this function to two inputs, or throws an exception if unable to do so.ClosingFuture.Combiner3.AsyncClosingFunction3.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3) Applies this function to three inputs, or throws an exception if unable to do so.ClosingFuture.Combiner3.AsyncClosingFunction3.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3) Applies this function to three inputs, or throws an exception if unable to do so.ClosingFuture.Combiner3.AsyncClosingFunction3.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3) Applies this function to three inputs, or throws an exception if unable to do so.ClosingFuture.Combiner3.ClosingFunction3.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3) Applies this function to three inputs, or throws an exception if unable to do so.ClosingFuture.Combiner3.ClosingFunction3.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3) Applies this function to three inputs, or throws an exception if unable to do so.ClosingFuture.Combiner3.ClosingFunction3.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3) Applies this function to three inputs, or throws an exception if unable to do so.ClosingFuture.Combiner4.AsyncClosingFunction4.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3, V4 value4) Applies this function to four inputs, or throws an exception if unable to do so.ClosingFuture.Combiner4.AsyncClosingFunction4.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3, V4 value4) Applies this function to four inputs, or throws an exception if unable to do so.ClosingFuture.Combiner4.AsyncClosingFunction4.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3, V4 value4) Applies this function to four inputs, or throws an exception if unable to do so.ClosingFuture.Combiner4.AsyncClosingFunction4.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3, V4 value4) Applies this function to four inputs, or throws an exception if unable to do so.ClosingFuture.Combiner4.ClosingFunction4.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3, V4 value4) Applies this function to four inputs, or throws an exception if unable to do so.ClosingFuture.Combiner4.ClosingFunction4.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3, V4 value4) Applies this function to four inputs, or throws an exception if unable to do so.ClosingFuture.Combiner4.ClosingFunction4.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3, V4 value4) Applies this function to four inputs, or throws an exception if unable to do so.ClosingFuture.Combiner4.ClosingFunction4.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3, V4 value4) Applies this function to four inputs, or throws an exception if unable to do so.ClosingFuture.Combiner5.AsyncClosingFunction5.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3, V4 value4, V5 value5) Applies this function to five inputs, or throws an exception if unable to do so.ClosingFuture.Combiner5.AsyncClosingFunction5.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3, V4 value4, V5 value5) Applies this function to five inputs, or throws an exception if unable to do so.ClosingFuture.Combiner5.AsyncClosingFunction5.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3, V4 value4, V5 value5) Applies this function to five inputs, or throws an exception if unable to do so.ClosingFuture.Combiner5.AsyncClosingFunction5.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3, V4 value4, V5 value5) Applies this function to five inputs, or throws an exception if unable to do so.ClosingFuture.Combiner5.AsyncClosingFunction5.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3, V4 value4, V5 value5) Applies this function to five inputs, or throws an exception if unable to do so.ClosingFuture.Combiner5.ClosingFunction5.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3, V4 value4, V5 value5) Applies this function to five inputs, or throws an exception if unable to do so.ClosingFuture.Combiner5.ClosingFunction5.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3, V4 value4, V5 value5) Applies this function to five inputs, or throws an exception if unable to do so.ClosingFuture.Combiner5.ClosingFunction5.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3, V4 value4, V5 value5) Applies this function to five inputs, or throws an exception if unable to do so.ClosingFuture.Combiner5.ClosingFunction5.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3, V4 value4, V5 value5) Applies this function to five inputs, or throws an exception if unable to do so.ClosingFuture.Combiner5.ClosingFunction5.apply
(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3, V4 value4, V5 value5) Applies this function to five inputs, or throws an exception if unable to do so.(package private) <V,
U> FluentFuture <U> ClosingFuture.CloseableList.applyAsyncClosingFunction
(ClosingFuture.AsyncClosingFunction<V, U> transformation, V input) (package private) <V,
U> ListenableFuture <U> ClosingFuture.CloseableList.applyClosingFunction
(ClosingFuture.ClosingFunction<? super V, U> transformation, V input) (package private) abstract void
AggregateFuture.collectOneValue
(int index, InputT returnValue) IfallMustSucceed
is true, called as each future completes; otherwise, ifcollectsValues
is true, called for each future when all futures complete.(package private) final void
CollectionFuture.collectOneValue
(int index, V returnValue) static <V> ListenableFutureTask
<V> Creates aListenableFutureTask
that will upon running, execute the givenRunnable
, and arrange thatget
will return the given result on successful completion.(package private) static <V> TrustedListenableFutureTask
<V> Creates aListenableFutureTask
that will upon running, execute the givenRunnable
, and arrange thatget
will return the given result on successful completion.(package private) ListenableFuture
<? extends O> AbstractTransformFuture.AsyncTransformFuture.doTransform
(AsyncFunction<? super I, ? extends O> function, I input) (package private) abstract T
AbstractTransformFuture.doTransform
(F function, I result) Template method for subtypes to actually run the transform.(package private) O
AbstractTransformFuture.TransformFuture.doTransform
(Function<? super I, ? extends O> function, I input) <C extends Object & AutoCloseable>
CClosingFuture.DeferredCloser.eventuallyClose
(C closeable, Executor closingExecutor) Captures an object to be closed when aClosingFuture
pipeline is done.static <V> ListenableFuture
<V> Futures.immediateFuture
(V value) Creates aListenableFuture
which has its value set immediately upon construction.static <V> AtomicReference
<V> Atomics.newReference
(V initialValue) Creates anAtomicReference
instance with the given initial value.protected final <T> RunnableFuture
<T> AbstractListeningExecutorService.newTaskFor
(Runnable runnable, T value) void
Invoked with the result of theFuture
computation when it is successful.static <T> Callable
<T> Callables.returning
(T value) Creates aCallable
which immediately returns a preset value each time it is called.protected boolean
Sets the result of thisFuture
unless thisFuture
has already been cancelled or set (including set asynchronously).boolean
(package private) void
(package private) abstract void
Template method for subtypes to actually set the result.(package private) abstract void
Template method for subtypes to actually set the result.(package private) void
(package private) void
(package private) abstract void
<T> ListenableFuture
<T> <T> Future
<T> <T> ListenableFuture
<T> <T> ListenableFuture
<T> final <T> Future
<T> Constructor parameters in com.google.common.util.concurrent with annotations of type ParametricNullnessModifierConstructorDescription(package private)
ImmediateFuture
(V value) (package private)
ListenableFutureTask
(Runnable runnable, V result) (package private)