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 ParametricNullnessMethods 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> VClosingFuture.Peeker.call(ClosingFuture.Combiner.CombiningCallable<V> combiner, ClosingFuture.CloseableList closeables) <T> TFakeTimeLimiter.callUninterruptiblyWithTimeout(Callable<T> callable, long timeoutDuration, TimeUnit timeoutUnit) <T> TFakeTimeLimiter.callWithTimeout(Callable<T> callable, long timeoutDuration, TimeUnit timeoutUnit) (package private) VAbstractCatchingFuture.CatchingFuture.doFallback(Function<? super X, ? extends V> fallback, X cause) (package private) abstract TAbstractCatchingFuture.doFallback(F fallback, X throwable) Template method for subtypes to actually run the fallback.(package private) abstract TAbstractTransformFuture.doTransform(F function, I result) Template method for subtypes to actually run the transform.(package private) OAbstractTransformFuture.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 aClosingFuturepipeline is done.AbstractFuture.get()final VAbstractFuture.TrustedFuture.get()final VClosingFuture.ValueAndCloser.get()Returns the final value of the associatedClosingFuture, or throws an exception asFuture.get()would.final VFluentFuture.TrustedFuture.get()final VForwardingFluentFuture.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> DClosingFuture.Peeker.getDone(ClosingFuture<D> closingFuture) Returns the value ofclosingFuture.static <V> VReturns the result of the inputFuture, which must have already completed.private VAbstractFuture.getDoneValue(Object obj) Unboxesobj.static <V> VFutures.getUnchecked(Future<V> future) Returns the result of callingFuture.get()uninterruptibly on a task known not to throw a checked exception.private static <V> VAbstractFuture.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> VUninterruptibles.getUninterruptibly(Future<V> future) Invokesfuture.get()uninterruptibly.static <V> VUninterruptibles.getUninterruptibly(Future<V> future, long timeout, TimeUnit unit) Invokesfuture.get(timeout, unit)uninterruptibly.static <V> VUninterruptibles.getUninterruptibly(Future<V> future, Duration timeout) Invokesfuture.get(timeout, unit)uninterruptibly.(package private) static <T> TMoreExecutors.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>>)forListeningExecutorServiceimplementations.(package private) static <T> TMoreExecutors.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>>)forListeningExecutorServiceimplementations.(package private) VCombinedFuture.CallableInterruptibleTask.runInterruptibly()(package private) abstract TInterruptibleTask.runInterruptibly()Do interruptible work here - do not complete Futures here, as their listeners could be interrupted.(package private) VTrustedListenableFutureTask.TrustedFutureInterruptibleTask.runInterruptibly()(package private) static <T> TNullnessCasts.uncheckedCastNullableTToT(T t) Accepts aTand returns a plainT, without performing any check that that conversion is safe.(package private) static <T> TNullnessCasts.uncheckedNull()Returnsnullcast to any type.Method parameters in com.google.common.util.concurrent with annotations of type ParametricNullnessModifier and TypeMethodDescription(package private) final voidCombinedFuture.CombinedFutureInterruptibleTask.afterRanInterruptiblySuccess(T result) (package private) abstract voidInterruptibleTask.afterRanInterruptiblySuccess(T result) Any interruption that happens as a result of calling interruptTask will arrive before this method is called.(package private) voidTrustedListenableFutureTask.TrustedFutureInterruptibleTask.afterRanInterruptiblySuccess(V result) Returns an outputFutureto 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 voidAggregateFuture.collectOneValue(int index, InputT returnValue) IfallMustSucceedis true, called as each future completes; otherwise, ifcollectsValuesis true, called for each future when all futures complete.(package private) final voidCollectionFuture.collectOneValue(int index, V returnValue) static <V> ListenableFutureTask<V>Creates aListenableFutureTaskthat will upon running, execute the givenRunnable, and arrange thatgetwill return the given result on successful completion.(package private) static <V> TrustedListenableFutureTask<V>Creates aListenableFutureTaskthat will upon running, execute the givenRunnable, and arrange thatgetwill 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 TAbstractTransformFuture.doTransform(F function, I result) Template method for subtypes to actually run the transform.(package private) OAbstractTransformFuture.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 aClosingFuturepipeline is done.static <V> ListenableFuture<V>Futures.immediateFuture(V value) Creates aListenableFuturewhich has its value set immediately upon construction.static <V> AtomicReference<V>Atomics.newReference(V initialValue) Creates anAtomicReferenceinstance with the given initial value.protected final <T> RunnableFuture<T>AbstractListeningExecutorService.newTaskFor(Runnable runnable, T value) voidInvoked with the result of theFuturecomputation when it is successful.static <T> Callable<T>Callables.returning(T value) Creates aCallablewhich immediately returns a preset value each time it is called.protected booleanSets the result of thisFutureunless thisFuturehas already been cancelled or set (including set asynchronously).boolean(package private) void(package private) abstract voidTemplate method for subtypes to actually set the result.(package private) abstract voidTemplate 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)