Uses of Annotation Interface
com.google.common.util.concurrent.ElementTypesAreNonnullByDefault
Packages that use ElementTypesAreNonnullByDefault
-
Uses of ElementTypesAreNonnullByDefault in com.google.common.util.concurrent
Classes in com.google.common.util.concurrent with annotations of type ElementTypesAreNonnullByDefaultModifier and TypeClassDescription(package private) classAbstractCatchingFuture<V,X extends Throwable, F, T> Implementations ofFutures.catching*.classBase class for services that can implementAbstractExecutionThreadService.startUp(),AbstractExecutionThreadService.run()andAbstractExecutionThreadService.shutDown()methods.classAn abstract implementation ofListenableFuture, intended for advanced users only.classBase class for services that do not need a thread while "running" but may need one during startup and shutdown.classAbstractListeningExecutorServiceimplementation that createsListenableFutureinstances for eachRunnableandCallablesubmitted to it.classBase class for services that can implementAbstractScheduledService.startUp()andAbstractScheduledService.shutDown()but while in the "running" state need to perform a periodic task.classBase class for implementing services that can handleAbstractService.doStart()andAbstractService.doStop()requests, responding to them withAbstractService.notifyStarted()andAbstractService.notifyStopped()callbacks.(package private) classAbstractTransformFuture<I,O, F, T> Implementations ofFutures.transform*.(package private) classAggregateFuture<InputT,OutputT> A future whose value is derived from a collection of input futures.(package private) classAggregateFutureState<OutputT>A helper which does some thread-safe operations for aggregate futures, which must be implemented differently in GWT.interfaceComputes a value, possibly asynchronously.interfaceAsyncFunction<I,O> Transforms a value, possibly asynchronously.classAdoublevalue that may be updated atomically.classAdoublearray in which elements may be updated atomically.final classA map containinglongvalues that can be atomically updated.final classStatic utility methods pertaining to classes in thejava.util.concurrent.atomicpackage.final classStatic utility methods pertaining to theCallableinterface.final classA step in a pipeline of an asynchronous computation.(package private) classCollectionFuture<V,C> Aggregate future that collects (stores) results of each future.(package private) final classAggregate future that computes its value by calling a callable.classTheCycleDetectingLockFactorycreatesReentrantLockinstances andReentrantReadWriteLockinstances that detect potential deadlock by checking for cycles in lock acquisition order.(package private) enumclassErrorvariant ofExecutionException.final classA support class forListenableFutureimplementations to manage their listeners.final classSerializes execution of tasks, somewhat like an "asynchronoussynchronizedblock." Each enqueued callable will not be submitted to its associated executor until the previous callable has returned -- and, if the previous callable was anAsyncCallable, not until theFutureit returned is done (successful, failed, or cancelled).final classA TimeLimiter implementation which actually does not attempt to limit time at all.classFluentFuture<V>AListenableFuturethat supports fluent chains of operations.classABlockingDequewhich forwards all its method calls to anotherBlockingDeque.classABlockingQueuewhich forwards all its method calls to anotherBlockingQueue.(package private) classForwarding wrapper around aCondition.classAn executor service which forwards all its method calls to another executor service.(package private) final classFluentFuturethat forwards all calls to a delegate.classAFuturewhich forwards all its method calls to another future.classAListenableFuturewhich forwards all its method calls to another future.classA listening executor service which forwards all its method calls to another listening executor service.(package private) classForwarding wrapper around aLock.interfaceA callback for accepting the results of aFuturecomputation asynchronously.final classStatic utility methods pertaining to theFutureinterface.(package private) final classStatic methods used to implementFutures.getChecked(Future, Class).(package private) classHidden superclass ofFluentFuturethat provides us a place to declare special GWT versions of theFluentFuture.catchingfamily of methods.(package private) classHidden superclass ofFuturesthat provides us a place to declare special GWT versions of theFutures.catchingfamily of methods.(package private) classImplementation ofFutures.immediateFuture(V).(package private) final classThis class is forcom.google.common.util.concurrentuse only!(package private) classfinal classUtilities necessary for working with libraries that supply plainFutureinstances.classAFutureTaskthat also implements theListenableFutureinterface.interfaceHelper interface to implement bothListenableFutureandScheduledFuture.(package private) final classA list of listeners for implementing a concurrency friendly observable object.interfaceAnExecutorServicethat returnsListenableFutureinstances.interfaceAScheduledExecutorServicethat returnsListenableFutureinstances from itsExecutorServicemethods.final classA synchronization abstraction supporting waiting on arbitrary boolean conditions.final class(package private) final classA utility method to perform unchecked casts to suppress errors produced by nullness analyses.(package private) final classWorks around an android bug, where parking for more than INT_MAX seconds can produce an abort signal on 32 bit devices running Android Q.(package private) final classOuter class that exists solely to let us writePartially.GwtIncompatibleinstead of plainGwtIncompatible.(package private) final classMethods factored out so that they can be emulated differently in GWT.classA rate limiter.final classStatic utility methods pertaining to theRunnableinterface.(package private) final classExecutor ensuring that all Runnables submitted are executed in order, using the provided Executor, and sequentially such that no two will ever be running at the same time.interfaceAn object with an operational state, plus asynchronousService.startAsync()andService.stopAsync()lifecycle methods to transition between states.final classA manager for monitoring and controlling a set of services.(package private) interfaceSuperinterface ofServiceManagerto introduce a bridge method forservicesByState(), to ensure binary compatibility with older Guava versions that specifiedservicesByState()to returnImmutableMultimap.final classAListenableFuturewhose result can be set by aSettableFuture.set(Object),SettableFuture.setException(Throwable)orSettableFuture.setFuture(ListenableFuture)call.final classA TimeLimiter that runs method calls in the background using anExecutorService.(package private) classclassStriped<L>A stripedLock/Semaphore/ReadWriteLock.final classA ThreadFactory builder, providing any combination of these features: whether threads should be marked as daemon threads a naming format a thread priority an uncaught exception handler a backing thread factoryinterfaceImposes a time limit on method calls.(package private) final classImplementation ofFutures#withTimeout.(package private) classARunnableFuturethat also implements theListenableFutureinterface.final classFactories forThread.UncaughtExceptionHandlerinstances.classUnchecked variant ofExecutionException.classUnchecked version ofTimeoutException.final classUtilities for treating interruptible operations as uninterruptible.(package private) classAn abstractExecutorServicethat allows subclasses to wrap tasks before they are submitted to the underlying executor.(package private) classAn abstractScheduledExecutorServicethat allows subclasses to wrap tasks before they are submitted to the underlying executor.