Uses of Class
com.google.common.annotations.J2ktIncompatible
-
Packages that use J2ktIncompatible Package Description com.google.common.base Basic utility libraries and interfaces.com.google.common.collect Collection interfaces and implementations, and other utilities for collections.com.google.common.io Utility methods and classes for I/O; for example input streams, output streams, readers, writers, and files.com.google.common.math Arithmetic functions operating on primitive values and onBigIntegerandBigDecimalinstances.com.google.common.net Utility methods and classes for networking (such as IP addresses and domain names).com.google.common.primitives Static utilities for the eight primitive types andvoid, and value types for treating them as unsigned or storing them in immutable arrays.com.google.common.util.concurrent Concurrency utilities. -
-
Uses of J2ktIncompatible in com.google.common.base
Classes in com.google.common.base with annotations of type J2ktIncompatible Modifier and Type Class Description classDefaultsThis class provides default values for all Java types, as defined by the JLS.classEnumsUtility methods for working withEnuminstances.classFinalizablePhantomReference<T>Phantom reference with afinalizeReferent()method which a background thread invokes after the garbage collector reclaims the referent.interfaceFinalizableReferenceImplemented by references that have code to run after garbage collection of their referents.classFinalizableReferenceQueueA reference queue with an associated background thread that dequeues references and invokesFinalizableReference.finalizeReferent()on them.classFinalizableSoftReference<T>Soft reference with afinalizeReferent()method which a background thread invokes after the garbage collector reclaims the referent.classFinalizableWeakReference<T>Weak reference with afinalizeReferent()method which a background thread invokes after the garbage collector reclaims the referent.classStandardSystemPropertyRepresents a standard system property.Fields in com.google.common.base with annotations of type J2ktIncompatible Modifier and Type Field Description static java.nio.charset.CharsetCharsets. US_ASCIIUS-ASCII: seven-bit ASCII, the Basic Latin block of the Unicode character set (ISO646-US).static java.nio.charset.CharsetCharsets. UTF_16UTF-16: sixteen-bit UCS Transformation Format, byte order identified by an optional byte-order mark.static java.nio.charset.CharsetCharsets. UTF_16BEUTF-16BE: sixteen-bit UCS Transformation Format, big-endian byte order.static java.nio.charset.CharsetCharsets. UTF_16LEUTF-16LE: sixteen-bit UCS Transformation Format, little-endian byte order.Methods in com.google.common.base with annotations of type J2ktIncompatible Modifier and Type Method Description java.time.DurationStopwatch. elapsed()Returns the current elapsed time shown on this stopwatch as aDuration.static java.util.List<java.lang.StackTraceElement>Throwables. lazyStackTrace(java.lang.Throwable throwable)Deprecated.This method is equivalent toThrowable.getStackTrace()on JDK versions past JDK 8 and on all Android versions.static booleanThrowables. lazyStackTraceIsLazy()Deprecated.This method always returns false on JDK versions past JDK 8 and on all Android versions.static <T extends @Nullable java.lang.Object>
Supplier<T>Suppliers. memoizeWithExpiration(Supplier<T> delegate, java.time.Duration duration)Returns a supplier that caches the instance supplied by the delegate and removes the cached value after the specified time has passed.static java.lang.RuntimeExceptionThrowables. propagate(java.lang.Throwable throwable)Deprecated.To preserve behavior, usethrow eorthrow new RuntimeException(e)directly, or use a combination ofThrowables.throwIfUnchecked(java.lang.Throwable)andthrow new RuntimeException(e).static <X extends java.lang.Throwable>
voidThrowables. propagateIfInstanceOf(java.lang.Throwable throwable, java.lang.Class<X> declaredType)Deprecated.UseThrowables.throwIfInstanceOf(java.lang.Throwable, java.lang.Class<X>), which has the same behavior but rejectsnull.static voidThrowables. propagateIfPossible(java.lang.Throwable throwable)Deprecated.UseThrowables.throwIfUnchecked(java.lang.Throwable), which has the same behavior but rejectsnull.static <X extends java.lang.Throwable>
voidThrowables. propagateIfPossible(java.lang.Throwable throwable, java.lang.Class<X> declaredType)Deprecated.Use a combination ofThrowables.throwIfInstanceOf(java.lang.Throwable, java.lang.Class<X>)andThrowables.throwIfUnchecked(java.lang.Throwable), which togther provide the same behavior except that they rejectnull.static <X1 extends java.lang.Throwable,X2 extends java.lang.Throwable>
voidThrowables. propagateIfPossible(java.lang.Throwable throwable, java.lang.Class<X1> declaredType1, java.lang.Class<X2> declaredType2)Deprecated.Use a combination of two calls toThrowables.throwIfInstanceOf(java.lang.Throwable, java.lang.Class<X>)and one call toThrowables.throwIfUnchecked(java.lang.Throwable), which togther provide the same behavior except that they rejectnull.static Predicate<java.lang.Class<?>>Predicates. subtypeOf(java.lang.Class<?> clazz)Returns a predicate that evaluates totrueif the class being tested is assignable to (is a subtype of)clazz.static <T extends @Nullable java.lang.Object>
Supplier<T>Suppliers. synchronizedSupplier(Supplier<T> delegate)Returns a supplier whoseget()method synchronizes ondelegatebefore calling it, making it thread-safe. -
Uses of J2ktIncompatible in com.google.common.collect
Classes in com.google.common.collect with annotations of type J2ktIncompatible Modifier and Type Class Description classConcurrentHashMultiset<E>A multiset that supports concurrent modifications and that provides atomic versions of mostMultisetoperations (exceptions where noted).classEnumBiMap<K extends java.lang.Enum<K>,V extends java.lang.Enum<V>>ABiMapbacked by twoEnumMapinstances.classEnumHashBiMap<K extends java.lang.Enum<K>,V extends @Nullable java.lang.Object>ABiMapbacked by anEnumMapinstance for keys-to-values, and aHashMapinstance for values-to-keys.classEnumMultiset<E extends java.lang.Enum<E>>Multiset implementation specialized for enum elements, supporting all single-element operations in O(1).classForwardingBlockingDeque<E>Deprecated.This class has moved tocom.google.common.util.concurrent.classForwardingDeque<E extends @Nullable java.lang.Object>A deque which forwards all its method calls to another deque.interfaceInterner<E>Provides similar behavior toString.intern()for any immutable type.classInternersContains static methods pertaining to instances ofInterner.classMapMakerA builder ofConcurrentMapinstances that can have keys or values automatically wrapped in weak references.classMutableClassToInstanceMap<B extends @Nullable java.lang.Object>A mutable class-to-instance map backed by an arbitrary user-provided map.Methods in com.google.common.collect with annotations of type J2ktIncompatible Modifier and Type Method Description static Ordering<@Nullable java.lang.Object>Ordering. arbitrary()Returns an arbitrary ordering over all objects, for whichcompare(a, b) == 0impliesa == b(identity equality).static <E extends java.lang.Enum<E>>
java.util.EnumSet<E>Sets. complementOf(java.util.Collection<E> collection)Creates anEnumSetconsisting of all enum values that are not in the specified collection.static <E extends java.lang.Enum<E>>
java.util.EnumSet<E>Sets. complementOf(java.util.Collection<E> collection, java.lang.Class<E> type)Creates anEnumSetconsisting of all enum values that are not in the specified collection.static <E> intQueues. drain(java.util.concurrent.BlockingQueue<E> q, java.util.Collection<? super E> buffer, int numElements, long timeout, java.util.concurrent.TimeUnit unit)Drains the queue asBlockingQueue.drainTo(Collection, int), but if the requestednumElementselements are not available, it will wait for them up to the specified timeout.static <E> intQueues. drain(java.util.concurrent.BlockingQueue<E> q, java.util.Collection<? super E> buffer, int numElements, java.time.Duration timeout)Drains the queue asBlockingQueue.drainTo(Collection, int), but if the requestednumElementselements are not available, it will wait for them up to the specified timeout.static <E> intQueues. drainUninterruptibly(java.util.concurrent.BlockingQueue<E> q, java.util.Collection<? super E> buffer, int numElements, long timeout, java.util.concurrent.TimeUnit unit)Drains the queue as Queues.drain(BlockingQueue, Collection, int, long, TimeUnit), but with a different behavior in case it is interrupted while waiting.static <E> intQueues. drainUninterruptibly(java.util.concurrent.BlockingQueue<E> q, java.util.Collection<? super E> buffer, int numElements, java.time.Duration timeout)Drains the queue as Queues.drain(BlockingQueue, Collection, int, Duration), but with a different behavior in case it is interrupted while waiting.static ImmutableMap<java.lang.String,java.lang.String>Maps. fromProperties(java.util.Properties properties)Creates anImmutableMap<String, String>from aPropertiesinstance.static <E> java.util.concurrent.ArrayBlockingQueue<E>Queues. newArrayBlockingQueue(int capacity)Creates an emptyArrayBlockingQueuewith the given (fixed) capacity and nonfair access policy.static <E> java.util.concurrent.ConcurrentLinkedQueue<E>Queues. newConcurrentLinkedQueue()Creates an emptyConcurrentLinkedQueue.static <E> java.util.concurrent.ConcurrentLinkedQueue<E>Queues. newConcurrentLinkedQueue(java.lang.Iterable<? extends E> elements)Creates aConcurrentLinkedQueuecontaining the elements of the specified iterable, in the order they are returned by the iterable's iterator.static <E extends @Nullable java.lang.Object>
java.util.concurrent.CopyOnWriteArrayList<E>Lists. newCopyOnWriteArrayList()Creates an emptyCopyOnWriteArrayListinstance.static <E extends @Nullable java.lang.Object>
java.util.concurrent.CopyOnWriteArrayList<E>Lists. newCopyOnWriteArrayList(java.lang.Iterable<? extends E> elements)Creates aCopyOnWriteArrayListinstance containing the given elements.static <E extends @Nullable java.lang.Object>
java.util.concurrent.CopyOnWriteArraySet<E>Sets. newCopyOnWriteArraySet()Creates an emptyCopyOnWriteArraySetinstance.static <E extends @Nullable java.lang.Object>
java.util.concurrent.CopyOnWriteArraySet<E>Sets. newCopyOnWriteArraySet(java.lang.Iterable<? extends E> elements)Creates aCopyOnWriteArraySetinstance containing the given elements.static <E> java.util.concurrent.LinkedBlockingDeque<E>Queues. newLinkedBlockingDeque()Creates an emptyLinkedBlockingDequewith a capacity ofInteger.MAX_VALUE.static <E> java.util.concurrent.LinkedBlockingDeque<E>Queues. newLinkedBlockingDeque(int capacity)Creates an emptyLinkedBlockingDequewith the given (fixed) capacity.static <E> java.util.concurrent.LinkedBlockingDeque<E>Queues. newLinkedBlockingDeque(java.lang.Iterable<? extends E> elements)Creates aLinkedBlockingDequewith a capacity ofInteger.MAX_VALUE, containing the elements of the specified iterable, in the order they are returned by the iterable's iterator.static <E> java.util.concurrent.LinkedBlockingQueue<E>Queues. newLinkedBlockingQueue()Creates an emptyLinkedBlockingQueuewith a capacity ofInteger.MAX_VALUE.static <E> java.util.concurrent.LinkedBlockingQueue<E>Queues. newLinkedBlockingQueue(int capacity)Creates an emptyLinkedBlockingQueuewith the given (fixed) capacity.static <E> java.util.concurrent.LinkedBlockingQueue<E>Queues. newLinkedBlockingQueue(java.lang.Iterable<? extends E> elements)Creates aLinkedBlockingQueuewith a capacity ofInteger.MAX_VALUE, containing the elements of the specified iterable, in the order they are returned by the iterable's iterator.static <E extends java.lang.Comparable>
java.util.concurrent.PriorityBlockingQueue<E>Queues. newPriorityBlockingQueue()Creates an emptyPriorityBlockingQueuewith the ordering given by its elements' natural ordering.static <E extends java.lang.Comparable>
java.util.concurrent.PriorityBlockingQueue<E>Queues. newPriorityBlockingQueue(java.lang.Iterable<? extends E> elements)Creates aPriorityBlockingQueuecontaining the given elements.static <E> java.util.concurrent.SynchronousQueue<E>Queues. newSynchronousQueue()Creates an emptySynchronousQueuewith nonfair access policy.static <K extends @Nullable java.lang.Object,V extends @Nullable java.lang.Object>
BiMap<K,V>Maps. synchronizedBiMap(BiMap<K,V> bimap)Returns a synchronized (thread-safe) bimap backed by the specified bimap.static <E extends @Nullable java.lang.Object>
java.util.Deque<E>Queues. synchronizedDeque(java.util.Deque<E> deque)Returns a synchronized (thread-safe) deque backed by the specified deque.static <K extends @Nullable java.lang.Object,V extends @Nullable java.lang.Object>
ListMultimap<K,V>Multimaps. synchronizedListMultimap(ListMultimap<K,V> multimap)Returns a synchronized (thread-safe)ListMultimapbacked by the specified multimap.static <K extends @Nullable java.lang.Object,V extends @Nullable java.lang.Object>
Multimap<K,V>Multimaps. synchronizedMultimap(Multimap<K,V> multimap)Returns a synchronized (thread-safe) multimap backed by the specified multimap.static <K extends @Nullable java.lang.Object,V extends @Nullable java.lang.Object>
java.util.NavigableMap<K,V>Maps. synchronizedNavigableMap(java.util.NavigableMap<K,V> navigableMap)Returns a synchronized (thread-safe) navigable map backed by the specified navigable map.static <E extends @Nullable java.lang.Object>
java.util.NavigableSet<E>Sets. synchronizedNavigableSet(java.util.NavigableSet<E> navigableSet)Returns a synchronized (thread-safe) navigable set backed by the specified navigable set.static <E extends @Nullable java.lang.Object>
java.util.Queue<E>Queues. synchronizedQueue(java.util.Queue<E> queue)Returns a synchronized (thread-safe) queue backed by the specified queue.static <K extends @Nullable java.lang.Object,V extends @Nullable java.lang.Object>
SetMultimap<K,V>Multimaps. synchronizedSetMultimap(SetMultimap<K,V> multimap)Returns a synchronized (thread-safe)SetMultimapbacked by the specified multimap.static <K extends @Nullable java.lang.Object,V extends @Nullable java.lang.Object>
SortedSetMultimap<K,V>Multimaps. synchronizedSortedSetMultimap(SortedSetMultimap<K,V> multimap)Returns a synchronized (thread-safe)SortedSetMultimapbacked by the specified multimap.static <R extends @Nullable java.lang.Object,C extends @Nullable java.lang.Object,V extends @Nullable java.lang.Object>
Table<R,C,V>Tables. synchronizedTable(Table<R,C,V> table)Returns a synchronized (thread-safe) table backed by the specified table.java.lang.Object[]EvictingQueue. toArray()java.lang.Object[]ImmutableCollection. toArray()java.lang.Object[]MinMaxPriorityQueue. toArray() -
Uses of J2ktIncompatible in com.google.common.io
Classes in com.google.common.io with annotations of type J2ktIncompatible Modifier and Type Interface Description interfaceByteArrayDataInputAn extension ofDataInputfor reading from in-memory byte arrays; its methods offer identical functionality but do not throwIOException.interfaceByteArrayDataOutputAn extension ofDataOutputfor writing to in-memory byte arrays; its methods offer identical functionality but do not throwIOException.interfaceByteProcessor<T extends @Nullable java.lang.Object>A callback interface to process bytes from a stream.classByteSinkA destination to which bytes can be written, such as a file.classByteSourceA readable source of bytes, such as a file.classByteStreamsProvides utility methods for working with byte arrays and I/O streams.classCharSinkA destination to which characters can be written, such as a text file.classCharSourceA readable source of characters, such as a text file.classCharStreamsProvides utility methods for working with character streams.classCloseablesUtility methods for working withCloseableobjects.classCloserclassCountingInputStreamAnInputStreamthat counts the number of bytes read.classCountingOutputStreamAn OutputStream that counts the number of bytes written.classFileBackedOutputStreamAnOutputStreamthat starts buffering to a byte array, but switches to file buffering once the data reaches a configurable size.classFilesProvides utility methods for working with files.classFileWriteModeModes for opening a file for writing.classFlushablesUtility methods for working withFlushableobjects.classInsecureRecursiveDeleteExceptionException indicating that a recursive delete can't be performed because the file system does not have the support necessary to guarantee that it is not vulnerable to race conditions that would allow it to delete files and directories outside of the directory being deleted (i.e.,SecureDirectoryStreamis not supported).interfaceLineProcessor<T extends @Nullable java.lang.Object>A callback to be used with the streamingreadLinesmethods.classLineReaderA class for reading lines of text.classLittleEndianDataInputStreamAn implementation ofDataInputthat uses little-endian byte ordering for readingshort,int,float,double, andlongvalues.classLittleEndianDataOutputStreamAn implementation ofDataOutputthat uses little-endian byte ordering for writingchar,short,int,float,double, andlongvalues.classMoreFilesStatic utilities for use withPathinstances, intended to complementFiles.classPatternFilenameFilterFile name filter that only accepts files matching a regular expression.classRecursiveDeleteOptionOptions for use with recursive delete methods (MoreFiles.deleteRecursively(java.nio.file.Path, com.google.common.io.RecursiveDeleteOption...)andMoreFiles.deleteDirectoryContents(java.nio.file.Path, com.google.common.io.RecursiveDeleteOption...)).classResourcesProvides utility methods for working with resources in the classpath.Methods in com.google.common.io with annotations of type J2ktIncompatible Modifier and Type Method Description ByteSourceBaseEncoding. decodingSource(CharSource encodedSource)Returns aByteSourcethat reads base-encoded bytes from the specifiedCharSource.abstract java.io.InputStreamBaseEncoding. decodingStream(java.io.Reader reader)Returns anInputStreamthat decodes base-encoded input from the specifiedReader.ByteSinkBaseEncoding. encodingSink(CharSink encodedSink)Returns aByteSinkthat writes base-encoded bytes to the specifiedCharSink.abstract java.io.OutputStreamBaseEncoding. encodingStream(java.io.Writer writer)Returns anOutputStreamthat encodes bytes using this encoding into the specifiedWriter. -
Uses of J2ktIncompatible in com.google.common.math
Classes in com.google.common.math with annotations of type J2ktIncompatible Modifier and Type Class Description classBigDecimalMathA class for arithmetic onBigDecimalthat is not covered by its built-in methods.classLinearTransformationThe representation of a linear transformation between real numbersxandy.classPairedStatsAn immutable value object capturing some basic statistics about a collection of paired double values (e.g. points on a plane).classPairedStatsAccumulatorA mutable object which accumulates paired double values (e.g. points on a plane) and tracks some basic statistics over all the values added so far.classQuantilesProvides a fluent API for calculating quantiles.classStatsA bundle of statistical summary values -- sum, count, mean/average, min and max, and several forms of variance -- that were computed from a single set of zero or more floating-point values.classStatsAccumulatorA mutable object which accumulates double values and tracks some basic statistics over all the values added so far. -
Uses of J2ktIncompatible in com.google.common.net
Classes in com.google.common.net with annotations of type J2ktIncompatible Modifier and Type Class Description classHostSpecifierA syntactically valid host specifier, suitable for use in a URI.classInetAddressesStatic utility methods pertaining toInetAddressinstances. -
Uses of J2ktIncompatible in com.google.common.primitives
Classes in com.google.common.primitives with annotations of type J2ktIncompatible Modifier and Type Class Description classUnsignedBytesStatic utility methods pertaining tobyteprimitives that interpret values as unsigned (that is, any negative valuebis treated as the positive value256 + b).Methods in com.google.common.primitives with annotations of type J2ktIncompatible Modifier and Type Method Description UnsignedIntegerUnsignedInteger. times(UnsignedInteger val)Returns the result of multiplying this andval. -
Uses of J2ktIncompatible in com.google.common.util.concurrent
Classes in com.google.common.util.concurrent with annotations of type J2ktIncompatible Modifier and Type Class Description classAbstractExecutionThreadServiceBase class for services that can implementAbstractExecutionThreadService.startUp(),AbstractExecutionThreadService.run()andAbstractExecutionThreadService.shutDown()methods.classAbstractIdleServiceBase class for services that do not need a thread while "running" but may need one during startup and shutdown.classAbstractListeningExecutorServiceAbstractListeningExecutorServiceimplementation that createsListenableFutureinstances for eachRunnableandCallablesubmitted to it.classAbstractScheduledServiceBase class for services that can implementAbstractScheduledService.startUp()andAbstractScheduledService.shutDown()but while in the "running" state need to perform a periodic task.classAbstractServiceBase class for implementing services that can handleAbstractService.doStart()andAbstractService.doStop()requests, responding to them withAbstractService.notifyStarted()andAbstractService.notifyStopped()callbacks.classAtomicDoubleAdoublevalue that may be updated atomically.classAtomicDoubleArrayAdoublearray in which elements may be updated atomically.classAtomicLongMap<K>A map containinglongvalues that can be atomically updated.classClosingFuture<V extends @Nullable java.lang.Object>A step in a pipeline of an asynchronous computation.classCycleDetectingLockFactoryTheCycleDetectingLockFactorycreatesReentrantLockinstances andReentrantReadWriteLockinstances that detect potential deadlock by checking for cycles in lock acquisition order.classExecutionListA support class forListenableFutureimplementations to manage their listeners.classExecutionSequencerSerializes execution of tasks, somewhat like an "asynchronoussynchronizedblock."classFakeTimeLimiterA TimeLimiter implementation which actually does not attempt to limit time at all.classForwardingBlockingDeque<E>ABlockingDequewhich forwards all its method calls to anotherBlockingDeque.classForwardingBlockingQueue<E>ABlockingQueuewhich forwards all its method calls to anotherBlockingQueue.classForwardingExecutorServiceAn executor service which forwards all its method calls to another executor service.classForwardingListeningExecutorServiceA listening executor service which forwards all its method calls to another listening executor service.classJdkFutureAdaptersUtilities necessary for working with libraries that supply plainFutureinstances.classListenableFutureTask<V extends @Nullable java.lang.Object>AFutureTaskthat also implements theListenableFutureinterface.interfaceListeningScheduledExecutorServiceAScheduledExecutorServicethat returnsListenableFutureinstances from itsExecutorServicemethods.classMonitorA synchronization abstraction supporting waiting on arbitrary boolean conditions.classRateLimiterA rate limiter.interfaceServiceAn object with an operational state, plus asynchronousService.startAsync()andService.stopAsync()lifecycle methods to transition between states.classServiceManagerA manager for monitoring and controlling a set of services.classSimpleTimeLimiterA TimeLimiter that runs method calls in the background using anExecutorService.classStriped<L>A stripedLock/Semaphore/ReadWriteLock.classThreadFactoryBuilderA 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 factoryinterfaceTimeLimiterImposes a time limit on method calls.classUncaughtExceptionHandlersFactories forThread.UncaughtExceptionHandlerinstances.classUncheckedTimeoutExceptionUnchecked version ofTimeoutException.Methods in com.google.common.util.concurrent with annotations of type J2ktIncompatible Modifier and Type Method Description static voidMoreExecutors. addDelayedShutdownHook(java.util.concurrent.ExecutorService service, long terminationTimeout, java.util.concurrent.TimeUnit timeUnit)Add a shutdown hook to wait for thread completion in the givenservice.static voidMoreExecutors. addDelayedShutdownHook(java.util.concurrent.ExecutorService service, java.time.Duration terminationTimeout)Add a shutdown hook to wait for thread completion in the givenservice.static <T extends @Nullable java.lang.Object>
AsyncCallable<T>Callables. asAsyncCallable(java.util.concurrent.Callable<T> callable, ListeningExecutorService listeningExecutorService)Creates anAsyncCallablefrom aCallable.default booleanListeningExecutorService. awaitTermination(java.time.Duration timeout)Duration-based overload ofExecutorService.awaitTermination(long, TimeUnit).static voidUninterruptibles. awaitTerminationUninterruptibly(java.util.concurrent.ExecutorService executor)Invokesexecutor.awaitTermination(long, TimeUnit)uninterruptibly with no timeout.static booleanUninterruptibles. awaitTerminationUninterruptibly(java.util.concurrent.ExecutorService executor, long timeout, java.util.concurrent.TimeUnit unit)Invokesexecutor.awaitTermination(long, TimeUnit)uninterruptibly.static booleanUninterruptibles. awaitTerminationUninterruptibly(java.util.concurrent.ExecutorService executor, java.time.Duration timeout)Invokesexecutor.awaitTermination(long, TimeUnit)uninterruptibly.static voidUninterruptibles. awaitUninterruptibly(java.util.concurrent.CountDownLatch latch)Invokeslatch.await()uninterruptibly.static booleanUninterruptibles. awaitUninterruptibly(java.util.concurrent.CountDownLatch latch, long timeout, java.util.concurrent.TimeUnit unit)Invokeslatch.await(timeout, unit)uninterruptibly.static booleanUninterruptibles. awaitUninterruptibly(java.util.concurrent.CountDownLatch latch, java.time.Duration timeout)Invokeslatch.await(timeout, unit)uninterruptibly.static booleanUninterruptibles. awaitUninterruptibly(java.util.concurrent.locks.Condition condition, long timeout, java.util.concurrent.TimeUnit unit)Invokescondition.await(timeout, unit)uninterruptibly.static booleanUninterruptibles. awaitUninterruptibly(java.util.concurrent.locks.Condition condition, java.time.Duration timeout)Invokescondition.await(timeout, unit)uninterruptibly.<X extends java.lang.Throwable>
FluentFuture<V>FluentFuture. catching(java.lang.Class<X> exceptionType, Function<? super X,? extends V> fallback, java.util.concurrent.Executor executor)Returns aFuturewhose result is taken from thisFutureor, if thisFuturefails with the givenexceptionType, from the result provided by thefallback.static <V extends @Nullable java.lang.Object,X extends java.lang.Throwable>
ListenableFuture<V>Futures. catching(ListenableFuture<? extends V> input, java.lang.Class<X> exceptionType, Function<? super X,? extends V> fallback, java.util.concurrent.Executor executor)Returns aFuturewhose result is taken from the given primaryinputor, if the primary input fails with the givenexceptionType, from the result provided by thefallback.<X extends java.lang.Throwable>
FluentFuture<V>FluentFuture. catchingAsync(java.lang.Class<X> exceptionType, AsyncFunction<? super X,? extends V> fallback, java.util.concurrent.Executor executor)Returns aFuturewhose result is taken from thisFutureor, if thisFuturefails with the givenexceptionType, from the result provided by thefallback.static <V extends @Nullable java.lang.Object,X extends java.lang.Throwable>
ListenableFuture<V>Futures. catchingAsync(ListenableFuture<? extends V> input, java.lang.Class<X> exceptionType, AsyncFunction<? super X,? extends V> fallback, java.util.concurrent.Executor executor)Returns aFuturewhose result is taken from the given primaryinputor, if the primary input fails with the givenexceptionType, from the result provided by thefallback.static <V extends @Nullable java.lang.Object,X extends java.lang.Exception>
VFutures. getChecked(java.util.concurrent.Future<V> future, java.lang.Class<X> exceptionClass)Returns the result ofFuture.get(), converting most exceptions to a new instance of the given checked exception type.static <V extends @Nullable java.lang.Object,X extends java.lang.Exception>
VFutures. getChecked(java.util.concurrent.Future<V> future, java.lang.Class<X> exceptionClass, long timeout, java.util.concurrent.TimeUnit unit)Returns the result ofFuture.get(long, TimeUnit), converting most exceptions to a new instance of the given checked exception type.static <V extends @Nullable java.lang.Object,X extends java.lang.Exception>
VFutures. getChecked(java.util.concurrent.Future<V> future, java.lang.Class<X> exceptionClass, java.time.Duration timeout)Returns the result ofFuture.get(long, TimeUnit), converting most exceptions to a new instance of the given checked exception type.static java.util.concurrent.ExecutorServiceMoreExecutors. getExitingExecutorService(java.util.concurrent.ThreadPoolExecutor executor)Converts the given ThreadPoolExecutor into an ExecutorService that exits when the application is complete.static java.util.concurrent.ExecutorServiceMoreExecutors. getExitingExecutorService(java.util.concurrent.ThreadPoolExecutor executor, long terminationTimeout, java.util.concurrent.TimeUnit timeUnit)Converts the given ThreadPoolExecutor into an ExecutorService that exits when the application is complete.static java.util.concurrent.ExecutorServiceMoreExecutors. getExitingExecutorService(java.util.concurrent.ThreadPoolExecutor executor, java.time.Duration terminationTimeout)Converts the given ThreadPoolExecutor into an ExecutorService that exits when the application is complete.static java.util.concurrent.ScheduledExecutorServiceMoreExecutors. getExitingScheduledExecutorService(java.util.concurrent.ScheduledThreadPoolExecutor executor)Converts the given ScheduledThreadPoolExecutor into a ScheduledExecutorService that exits when the application is complete.static java.util.concurrent.ScheduledExecutorServiceMoreExecutors. getExitingScheduledExecutorService(java.util.concurrent.ScheduledThreadPoolExecutor executor, long terminationTimeout, java.util.concurrent.TimeUnit timeUnit)Converts the given ScheduledThreadPoolExecutor into a ScheduledExecutorService that exits when the application is complete.static java.util.concurrent.ScheduledExecutorServiceMoreExecutors. getExitingScheduledExecutorService(java.util.concurrent.ScheduledThreadPoolExecutor executor, java.time.Duration terminationTimeout)Converts the given ScheduledThreadPoolExecutor into a ScheduledExecutorService that exits when the application is complete.static <V extends @Nullable java.lang.Object>
VUninterruptibles. getUninterruptibly(java.util.concurrent.Future<V> future, long timeout, java.util.concurrent.TimeUnit unit)Invokesfuture.get(timeout, unit)uninterruptibly.static <V extends @Nullable java.lang.Object>
VUninterruptibles. getUninterruptibly(java.util.concurrent.Future<V> future, java.time.Duration timeout)Invokesfuture.get(timeout, unit)uninterruptibly.default <T extends @Nullable java.lang.Object>
java.util.List<java.util.concurrent.Future<T>>ListeningExecutorService. invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks, java.time.Duration timeout)Duration-based overload ofListeningExecutorService.invokeAll(Collection, long, TimeUnit).default <T extends @Nullable java.lang.Object>
TListeningExecutorService. invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks, java.time.Duration timeout)Duration-based overload ofExecutorService.invokeAny(Collection, long, TimeUnit).static voidUninterruptibles. joinUninterruptibly(java.lang.Thread toJoin)InvokestoJoin.join()uninterruptibly.static voidUninterruptibles. joinUninterruptibly(java.lang.Thread toJoin, long timeout, java.util.concurrent.TimeUnit unit)Invokesunit.timedJoin(toJoin, timeout)uninterruptibly.static voidUninterruptibles. joinUninterruptibly(java.lang.Thread toJoin, java.time.Duration timeout)Invokesunit.timedJoin(toJoin, timeout)uninterruptibly.static <I extends @Nullable java.lang.Object,O extends @Nullable java.lang.Object>
java.util.concurrent.Future<O>Futures. lazyTransform(java.util.concurrent.Future<I> input, Function<? super I,? extends O> function)LikeFutures.transform(ListenableFuture, Function, Executor)except that the transformationfunctionis invoked on each call toget()on the returned future.static ListeningExecutorServiceMoreExecutors. listeningDecorator(java.util.concurrent.ExecutorService delegate)Creates anExecutorServicewhosesubmitandinvokeAllmethods submitListenableFutureTaskinstances to the given delegate executor.static ListeningScheduledExecutorServiceMoreExecutors. listeningDecorator(java.util.concurrent.ScheduledExecutorService delegate)Creates aScheduledExecutorServicewhosesubmitandinvokeAllmethods submitListenableFutureTaskinstances to the given delegate executor.static java.util.concurrent.ThreadFactoryMoreExecutors. platformThreadFactory()Returns a default thread factory used to create new threads.static <E> voidUninterruptibles. putUninterruptibly(java.util.concurrent.BlockingQueue<E> queue, E element)Invokesqueue.put(element)uninterruptibly.static <O extends @Nullable java.lang.Object>
ListenableFuture<O>Futures. scheduleAsync(AsyncCallable<O> callable, long delay, java.util.concurrent.TimeUnit timeUnit, java.util.concurrent.ScheduledExecutorService executorService)Schedulescallableon the specifiedexecutor, returning aFuture.static <O extends @Nullable java.lang.Object>
ListenableFuture<O>Futures. scheduleAsync(AsyncCallable<O> callable, java.time.Duration delay, java.util.concurrent.ScheduledExecutorService executorService)Schedulescallableon the specifiedexecutor, returning aFuture.static booleanMoreExecutors. shutdownAndAwaitTermination(java.util.concurrent.ExecutorService service, long timeout, java.util.concurrent.TimeUnit unit)Shuts down the given executor service gradually, first disabling new submissions and later, if necessary, cancelling remaining tasks.static booleanMoreExecutors. shutdownAndAwaitTermination(java.util.concurrent.ExecutorService service, java.time.Duration timeout)Shuts down the given executor service gradually, first disabling new submissions and later, if necessary, cancelling remaining tasks.static voidUninterruptibles. sleepUninterruptibly(long sleepFor, java.util.concurrent.TimeUnit unit)Invokesunit.sleep(sleepFor)uninterruptibly.static voidUninterruptibles. sleepUninterruptibly(java.time.Duration sleepFor)Invokesunit.sleep(sleepFor)uninterruptibly.static <E> EUninterruptibles. takeUninterruptibly(java.util.concurrent.BlockingQueue<E> queue)Invokesqueue.take()uninterruptibly.static booleanUninterruptibles. tryAcquireUninterruptibly(java.util.concurrent.Semaphore semaphore, int permits, long timeout, java.util.concurrent.TimeUnit unit)Invokessemaphore.tryAcquire(permits, timeout, unit)uninterruptibly.static booleanUninterruptibles. tryAcquireUninterruptibly(java.util.concurrent.Semaphore semaphore, int permits, java.time.Duration timeout)Invokessemaphore.tryAcquire(permits, timeout, unit)uninterruptibly.static booleanUninterruptibles. tryAcquireUninterruptibly(java.util.concurrent.Semaphore semaphore, long timeout, java.util.concurrent.TimeUnit unit)Invokessemaphore.tryAcquire(1, timeout, unit)uninterruptibly.static booleanUninterruptibles. tryAcquireUninterruptibly(java.util.concurrent.Semaphore semaphore, java.time.Duration timeout)Invokessemaphore.tryAcquire(1, timeout, unit)uninterruptibly.static booleanUninterruptibles. tryLockUninterruptibly(java.util.concurrent.locks.Lock lock, long timeout, java.util.concurrent.TimeUnit unit)Invokeslock.tryLock(timeout, unit)uninterruptibly.static booleanUninterruptibles. tryLockUninterruptibly(java.util.concurrent.locks.Lock lock, java.time.Duration timeout)Invokeslock.tryLock(timeout, unit)uninterruptibly.FluentFuture<V>FluentFuture. withTimeout(long timeout, java.util.concurrent.TimeUnit unit, java.util.concurrent.ScheduledExecutorService scheduledExecutor)Returns a future that delegates to this future but will finish early (via aTimeoutExceptionwrapped in anExecutionException) if the specified timeout expires.FluentFuture<V>FluentFuture. withTimeout(java.time.Duration timeout, java.util.concurrent.ScheduledExecutorService scheduledExecutor)Returns a future that delegates to this future but will finish early (via aTimeoutExceptionwrapped in anExecutionException) if the specified timeout expires.static <V extends @Nullable java.lang.Object>
ListenableFuture<V>Futures. withTimeout(ListenableFuture<V> delegate, long time, java.util.concurrent.TimeUnit unit, java.util.concurrent.ScheduledExecutorService scheduledExecutor)Returns a future that delegates to another but will finish early (via aTimeoutExceptionwrapped in anExecutionException) if the specified duration expires.static <V extends @Nullable java.lang.Object>
ListenableFuture<V>Futures. withTimeout(ListenableFuture<V> delegate, java.time.Duration time, java.util.concurrent.ScheduledExecutorService scheduledExecutor)Returns a future that delegates to another but will finish early (via aTimeoutExceptionwrapped in anExecutionException) if the specified duration expires.
-