Package | Description |
---|---|
com.google.common.base |
Basic utility libraries and interfaces.
|
com.google.common.cache |
This package contains caching utilities.
|
com.google.common.collect |
This package contains generic collection interfaces and implementations, and
other utilities for working with collections.
|
com.google.common.io |
This package contains utility methods and classes for working with Java I/O;
for example input streams, output streams, readers, writers, and files.
|
com.google.common.math |
Arithmetic functions operating on primitive values and
BigInteger instances. |
com.google.common.primitives |
Static utilities for working with the eight primitive types and
void ,
and value types for treating them as unsigned. |
com.google.common.util.concurrent |
Concurrency utilities.
|
Modifier and Type | Class and Description |
---|---|
class |
StandardSystemProperty
Represents a standard system property.
|
Modifier and Type | Field and Description |
---|---|
static Charset |
Charsets.ISO_8859_1
ISO-8859-1: ISO Latin Alphabet Number 1 (ISO-LATIN-1).
|
static Charset |
Charsets.US_ASCII
US-ASCII: seven-bit ASCII, the Basic Latin block of the Unicode character set (ISO646-US).
|
static Charset |
Charsets.UTF_16
UTF-16: sixteen-bit UCS Transformation Format, byte order identified by an optional byte-order
mark.
|
static Charset |
Charsets.UTF_16BE
UTF-16BE: sixteen-bit UCS Transformation Format, big-endian byte order.
|
static Charset |
Charsets.UTF_16LE
UTF-16LE: sixteen-bit UCS Transformation Format, little-endian byte order.
|
Modifier and Type | Method and Description |
---|---|
static Predicate<Class<?>> |
Predicates.assignableFrom(Class<?> clazz)
Returns a predicate that evaluates to
true if the class being
tested is assignable from the given class. |
static Predicate<CharSequence> |
Predicates.contains(Pattern pattern)
Returns a predicate that evaluates to
true if the
CharSequence being tested contains any match for the given
regular expression pattern. |
static Predicate<CharSequence> |
Predicates.containsPattern(String pattern)
Returns a predicate that evaluates to
true if the
CharSequence being tested contains any match for the given
regular expression pattern. |
static Field |
Enums.getField(Enum<?> enumValue)
Returns the
Field in which enumValue is defined. |
static Predicate<Object> |
Predicates.instanceOf(Class<?> clazz)
Returns a predicate that evaluates to
true if the object being
tested is an instance of the given class. |
static Splitter |
Splitter.on(Pattern separatorPattern)
Returns a splitter that considers any subsequence matching
pattern to be a separator. |
static Splitter |
Splitter.onPattern(String separatorPattern)
Returns a splitter that considers any subsequence matching a given
pattern (regular expression) to be a separator.
|
String |
Stopwatch.toString()
Returns a string representation of the current elapsed time.
|
Modifier and Type | Method and Description |
---|---|
static <K,V> CacheLoader<K,V> |
CacheLoader.asyncReloading(CacheLoader<K,V> loader,
Executor executor)
Returns a
CacheLoader which wraps loader , executing calls to
CacheLoader.reload(K, V) using executor . |
static CacheBuilder<Object,Object> |
CacheBuilder.from(CacheBuilderSpec spec)
Constructs a new
CacheBuilder instance with the settings specified in spec . |
static CacheBuilder<Object,Object> |
CacheBuilder.from(String spec)
Constructs a new
CacheBuilder instance with the settings specified in spec . |
CacheBuilder<K,V> |
CacheBuilder.maximumWeight(long weight)
Specifies the maximum weight of entries the cache may contain.
|
CacheBuilder<K,V> |
CacheBuilder.refreshAfterWrite(long duration,
TimeUnit unit)
Specifies that active entries are eligible for automatic refresh once a fixed duration has
elapsed after the entry's creation, or the most recent replacement of its value.
|
ListenableFuture<V> |
CacheLoader.reload(K key,
V oldValue)
Computes or retrieves a replacement value corresponding to an already-cached
key . |
CacheBuilder<K,V> |
CacheBuilder.softValues()
Specifies that each value (not key) stored in the cache should be wrapped in a
SoftReference (by default, strong references are used). |
CacheBuilder<K,V> |
CacheBuilder.weakKeys()
Specifies that each key (not value) stored in the cache should be wrapped in a
WeakReference (by default, strong references are used). |
CacheBuilder<K,V> |
CacheBuilder.weakValues()
Specifies that each value (not key) stored in the cache should be wrapped in a
WeakReference (by default, strong references are used). |
<K1 extends K,V1 extends V> |
CacheBuilder.weigher(Weigher<? super K1,? super V1> weigher)
Specifies the weigher to use in determining the weight of entries.
|
Modifier and Type | Class and Description |
---|---|
class |
ImmutableRangeMap<K extends Comparable<?>,V>
A
RangeMap whose contents will never change, with many other important properties
detailed at ImmutableCollection . |
class |
ImmutableSortedMultiset<E>
A
SortedMultiset whose contents will never change, with many other important properties
detailed at ImmutableCollection . |
class |
TreeRangeMap<K extends Comparable,V>
An implementation of
RangeMap based on a TreeMap , supporting
all optional operations. |
class |
TreeRangeSet<C extends Comparable<?>>
|
Modifier and Type | Method and Description |
---|---|
NavigableMap<K,Collection<V>> |
TreeMultimap.asMap()
Returns a map view that associates each key with the corresponding values
in the multimap.
|
static <K,V> NavigableMap<K,V> |
Maps.asMap(NavigableSet<K> set,
Function<? super K,V> function)
Returns a view of the navigable set as a map, mapping keys from the set
according to the specified function.
|
E |
ImmutableSortedSet.ceiling(E e) |
static <T> T[] |
ObjectArrays.concat(T[] first,
T[] second,
Class<T> type)
Returns a new array that contains the concatenated contents of two arrays.
|
abstract UnmodifiableIterator<E> |
ImmutableSortedSet.descendingIterator() |
ImmutableSortedSet<E> |
ImmutableSortedSet.descendingSet() |
<T> FluentIterable<T> |
FluentIterable.filter(Class<T> type)
Returns the elements from this fluent iterable that are instances of class
type . |
static <T> Iterable<T> |
Iterables.filter(Iterable<?> unfiltered,
Class<T> type)
Returns all instances of class
type in unfiltered . |
static <T> UnmodifiableIterator<T> |
Iterators.filter(Iterator<?> unfiltered,
Class<T> type)
Returns all instances of class
type in unfiltered . |
static <E> NavigableSet<E> |
Sets.filter(NavigableSet<E> unfiltered,
Predicate<? super E> predicate)
Returns the elements of a
NavigableSet , unfiltered , that
satisfy a predicate. |
static <K,V> NavigableMap<K,V> |
Maps.filterEntries(NavigableMap<K,V> unfiltered,
Predicate<? super Map.Entry<K,V>> entryPredicate)
Returns a sorted map containing the mappings in
unfiltered that
satisfy a predicate. |
static <K,V> NavigableMap<K,V> |
Maps.filterKeys(NavigableMap<K,V> unfiltered,
Predicate<? super K> keyPredicate)
Returns a navigable map containing the mappings in
unfiltered whose
keys satisfy a predicate. |
static <K,V> NavigableMap<K,V> |
Maps.filterValues(NavigableMap<K,V> unfiltered,
Predicate<? super V> valuePredicate)
Returns a navigable map containing the mappings in
unfiltered whose
values satisfy a predicate. |
E |
ImmutableSortedSet.floor(E e) |
static ImmutableMap<String,String> |
Maps.fromProperties(Properties properties)
Creates an
ImmutableMap<String, String> from a Properties
instance. |
NavigableSet<V> |
TreeMultimap.get(K key) |
ContiguousSet<C> |
ContiguousSet.headSet(C toElement,
boolean inclusive) |
ImmutableSortedSet<E> |
ImmutableSortedSet.headSet(E toElement,
boolean inclusive) |
E |
ImmutableSortedSet.higher(E e) |
NavigableSet<K> |
TreeMultimap.keySet()
Returns a view collection of all distinct keys contained in this
multimap.
|
E |
ImmutableSortedSet.lower(E e) |
static <T> T[] |
ObjectArrays.newArray(Class<T> type,
int length)
Returns a new array of the given length with the specified component type.
|
static <E> CopyOnWriteArrayList<E> |
Lists.newCopyOnWriteArrayList()
Creates an empty
CopyOnWriteArrayList instance. |
static <E> CopyOnWriteArrayList<E> |
Lists.newCopyOnWriteArrayList(Iterable<? extends E> elements)
Creates a
CopyOnWriteArrayList instance containing the given elements. |
static <E> CopyOnWriteArraySet<E> |
Sets.newCopyOnWriteArraySet()
Creates an empty
CopyOnWriteArraySet instance. |
static <E> CopyOnWriteArraySet<E> |
Sets.newCopyOnWriteArraySet(Iterable<? extends E> elements)
Creates a
CopyOnWriteArraySet instance containing the given elements. |
static <E> Interner<E> |
Interners.newWeakInterner()
Returns a new thread-safe interner which retains a weak reference to each instance it has
interned, and so does not prevent these instances from being garbage-collected.
|
E |
ImmutableSortedSet.pollFirst()
Deprecated.
Unsupported operation.
|
E |
ImmutableSortedSet.pollLast()
Deprecated.
Unsupported operation.
|
ContiguousSet<C> |
ContiguousSet.subSet(C fromElement,
boolean fromInclusive,
C toElement,
boolean toInclusive) |
ImmutableSortedSet<E> |
ImmutableSortedSet.subSet(E fromElement,
boolean fromInclusive,
E toElement,
boolean toInclusive) |
static <K,V> NavigableMap<K,V> |
Maps.synchronizedNavigableMap(NavigableMap<K,V> navigableMap)
Returns a synchronized (thread-safe) navigable map backed by the specified
navigable map.
|
static <E> NavigableSet<E> |
Sets.synchronizedNavigableSet(NavigableSet<E> navigableSet)
Returns a synchronized (thread-safe) navigable set backed by the specified
navigable set.
|
ContiguousSet<C> |
ContiguousSet.tailSet(C fromElement,
boolean inclusive) |
ImmutableSortedSet<E> |
ImmutableSortedSet.tailSet(E fromElement,
boolean inclusive) |
E[] |
FluentIterable.toArray(Class<E> type)
Returns an array containing all of the elements from this fluent iterable in iteration order.
|
V[][] |
ArrayTable.toArray(Class<V> valueClass)
Returns a two-dimensional array with the table contents.
|
static <T> T[] |
Iterables.toArray(Iterable<? extends T> iterable,
Class<T> type)
Copies an iterable's elements into an array.
|
static <T> T[] |
Iterators.toArray(Iterator<? extends T> iterator,
Class<T> type)
Copies an iterator's elements into an array.
|
static <K,V1,V2> NavigableMap<K,V2> |
Maps.transformEntries(NavigableMap<K,V1> fromMap,
Maps.EntryTransformer<? super K,? super V1,V2> transformer)
Returns a view of a navigable map whose values are derived from the
original navigable map's entries.
|
static <K,V1,V2> NavigableMap<K,V2> |
Maps.transformValues(NavigableMap<K,V1> fromMap,
Function<? super V1,V2> function)
Returns a view of a navigable map where each value is transformed by a
function.
|
static <K,V> NavigableMap<K,V> |
Maps.unmodifiableNavigableMap(NavigableMap<K,V> map)
Returns an unmodifiable view of the specified navigable map.
|
static <E> NavigableSet<E> |
Sets.unmodifiableNavigableSet(NavigableSet<E> set)
Returns an unmodifiable view of the specified navigable set.
|
MapMaker |
MapMaker.weakKeys()
Specifies that each key (not value) stored in the map should be wrapped in a
WeakReference (by default, strong references are used). |
MapMaker |
MapMaker.weakValues()
Specifies that each value (not key) stored in the map should be wrapped in a
WeakReference (by default, strong references are used). |
Modifier and Type | Method and Description |
---|---|
ByteSource |
BaseEncoding.decodingSource(CharSource encodedSource)
Returns a
ByteSource that reads base-encoded bytes from the specified
CharSource . |
abstract InputStream |
BaseEncoding.decodingStream(Reader reader)
Returns an
InputStream that decodes base-encoded input from the specified
Reader . |
ByteSink |
BaseEncoding.encodingSink(CharSink encodedSink)
Returns a
ByteSink that writes base-encoded bytes to the specified CharSink . |
abstract OutputStream |
BaseEncoding.encodingStream(Writer writer)
Returns an
OutputStream that encodes bytes using this encoding into the specified
Writer . |
Modifier and Type | Method and Description |
---|---|
static int |
IntMath.binomial(int n,
int k)
Returns
n choose k , also known as the binomial coefficient of n and
k , or Integer.MAX_VALUE if the result does not fit in an int . |
static long |
LongMath.checkedAdd(long a,
long b)
Returns the sum of
a and b , provided it does not overflow. |
static long |
LongMath.checkedMultiply(long a,
long b)
Returns the product of
a and b , provided it does not overflow. |
static long |
LongMath.checkedPow(long b,
int k)
Returns the
b to the k th power, provided it does not overflow. |
static long |
LongMath.checkedSubtract(long a,
long b)
Returns the difference of
a and b , provided it does not overflow. |
static BigInteger |
BigIntegerMath.divide(BigInteger p,
BigInteger q,
RoundingMode mode)
Returns the result of dividing
p by q , rounding using the specified
RoundingMode . |
static long |
LongMath.divide(long p,
long q,
RoundingMode mode)
Returns the result of dividing
p by q , rounding using the specified
RoundingMode . |
static long |
LongMath.factorial(int n)
Returns
n! , that is, the product of the first n positive
integers, 1 if n == 0 , or Long.MAX_VALUE if the
result does not fit in a long . |
static boolean |
DoubleMath.isMathematicalInteger(double x)
Returns
true if x represents a mathematical integer. |
static boolean |
DoubleMath.isPowerOfTwo(double x)
Returns
true if x is exactly equal to 2^k for some finite integer
k . |
static int |
BigIntegerMath.log10(BigInteger x,
RoundingMode mode)
Returns the base-10 logarithm of
x , rounded according to the specified rounding mode. |
static int |
IntMath.log10(int x,
RoundingMode mode)
Returns the base-10 logarithm of
x , rounded according to the specified rounding mode. |
static int |
LongMath.log10(long x,
RoundingMode mode)
Returns the base-10 logarithm of
x , rounded according to the specified rounding mode. |
static int |
DoubleMath.log2(double x,
RoundingMode mode)
Returns the base 2 logarithm of a double value, rounded with the specified rounding mode to an
int . |
static double |
DoubleMath.mean(double... values)
Returns the arithmetic mean of
values . |
static double |
DoubleMath.mean(Iterable<? extends Number> values)
Returns the arithmetic mean of
values . |
static double |
DoubleMath.mean(Iterator<? extends Number> values)
Returns the arithmetic mean of
values . |
static int |
LongMath.mod(long x,
int m)
Returns
x mod m , a non-negative value less than m . |
static long |
LongMath.mod(long x,
long m)
Returns
x mod m , a non-negative value less than m . |
static int |
IntMath.pow(int b,
int k)
Returns
b to the k th power. |
static long |
LongMath.pow(long b,
int k)
Returns
b to the k th power. |
static BigInteger |
DoubleMath.roundToBigInteger(double x,
RoundingMode mode)
Returns the
BigInteger value that is equal to x rounded with the specified
rounding mode, if possible. |
static int |
DoubleMath.roundToInt(double x,
RoundingMode mode)
Returns the
int value that is equal to x rounded with the specified rounding
mode, if possible. |
static long |
DoubleMath.roundToLong(double x,
RoundingMode mode)
Returns the
long value that is equal to x rounded with the specified rounding
mode, if possible. |
static BigInteger |
BigIntegerMath.sqrt(BigInteger x,
RoundingMode mode)
Returns the square root of
x , rounded with the specified rounding mode. |
static int |
IntMath.sqrt(int x,
RoundingMode mode)
Returns the square root of
x , rounded with the specified rounding mode. |
static long |
LongMath.sqrt(long x,
RoundingMode mode)
Returns the square root of
x , rounded with the specified rounding mode. |
Modifier and Type | Method and Description |
---|---|
static int |
Ints.fromByteArray(byte[] bytes)
Returns the
int value whose big-endian representation is stored in
the first 4 bytes of bytes ; equivalent to ByteBuffer.wrap(bytes).getInt() . |
static short |
Shorts.fromByteArray(byte[] bytes)
Returns the
short value whose big-endian representation is
stored in the first 2 bytes of bytes ; equivalent to ByteBuffer.wrap(bytes).getShort() . |
static char |
Chars.fromByteArray(byte[] bytes)
Returns the
char value whose big-endian representation is
stored in the first 2 bytes of bytes ; equivalent to ByteBuffer.wrap(bytes).getChar() . |
static short |
Shorts.fromBytes(byte b1,
byte b2)
Returns the
short value whose byte representation is the given 2
bytes, in big-endian order; equivalent to Shorts.fromByteArray(new
byte[] {b1, b2}) . |
static char |
Chars.fromBytes(byte b1,
byte b2)
Returns the
char value whose byte representation is the given 2
bytes, in big-endian order; equivalent to Chars.fromByteArray(new
byte[] {b1, b2}) . |
static int |
Ints.fromBytes(byte b1,
byte b2,
byte b3,
byte b4)
Returns the
int value whose byte representation is the given 4
bytes, in big-endian order; equivalent to Ints.fromByteArray(new
byte[] {b1, b2, b3, b4}) . |
UnsignedInteger |
UnsignedInteger.times(UnsignedInteger val)
Returns the result of multiplying this and
val . |
static byte[] |
Chars.toByteArray(char value)
Returns a big-endian representation of
value in a 2-element byte
array; equivalent to ByteBuffer.allocate(2).putChar(value).array() . |
static byte[] |
Ints.toByteArray(int value)
Returns a big-endian representation of
value in a 4-element byte
array; equivalent to ByteBuffer.allocate(4).putInt(value).array() . |
static byte[] |
Shorts.toByteArray(short value)
Returns a big-endian representation of
value in a 2-element byte
array; equivalent to ByteBuffer.allocate(2).putShort(value).array() . |
static Double |
Doubles.tryParse(String string)
Parses the specified string as a double-precision floating point value.
|
static Float |
Floats.tryParse(String string)
Parses the specified string as a single-precision floating point value.
|
Modifier and Type | Method and Description |
---|---|
static void |
MoreExecutors.addDelayedShutdownHook(ExecutorService service,
long terminationTimeout,
TimeUnit timeUnit)
Add a shutdown hook to wait for thread completion in the given
service . |
static void |
Uninterruptibles.awaitUninterruptibly(CountDownLatch latch)
Invokes
latch. await()
uninterruptibly. |
static boolean |
Uninterruptibles.awaitUninterruptibly(CountDownLatch latch,
long timeout,
TimeUnit unit)
Invokes
latch. await(timeout, unit) uninterruptibly. |
static <V,X extends Throwable> |
Futures.catching(ListenableFuture<? extends V> input,
Class<X> exceptionType,
Function<? super X,? extends V> fallback)
Returns a
Future whose result is taken from the given primary input or, if the
primary input fails with the given exceptionType , from the result provided by the
fallback . |
static <V,X extends Throwable> |
Futures.catching(ListenableFuture<? extends V> input,
Class<X> exceptionType,
Function<? super X,? extends V> fallback,
Executor executor)
Returns a
Future whose result is taken from the given primary input or, if the
primary input fails with the given exceptionType , from the result provided by the
fallback . |
static <V,X extends Throwable> |
Futures.catchingAsync(ListenableFuture<? extends V> input,
Class<X> exceptionType,
AsyncFunction<? super X,? extends V> fallback)
Returns a
Future whose result is taken from the given primary input or, if the
primary input fails with the given exceptionType , from the result provided by the
fallback . |
static <V,X extends Throwable> |
Futures.catchingAsync(ListenableFuture<? extends V> input,
Class<X> exceptionType,
AsyncFunction<? super X,? extends V> fallback,
Executor executor)
Returns a
Future whose result is taken from the given primary input or, if the
primary input fails with the given exceptionType , from the result provided by the
fallback . |
static <V,X extends Exception> |
Futures.get(Future<V> future,
Class<X> exceptionClass)
Deprecated.
Use
Futures.getChecked(Future, Class) . This method will be
removed in Guava release 20.0. |
static <V,X extends Exception> |
Futures.get(Future<V> future,
long timeout,
TimeUnit unit,
Class<X> exceptionClass)
Deprecated.
Use
Futures.getChecked(Future, Class, long, TimeUnit) , noting
the change in parameter order. This method will be removed in Guava
release 20.0. |
static <V,X extends Exception> |
Futures.getChecked(Future<V> future,
Class<X> exceptionClass)
Returns the result of
Future.get() , converting most exceptions to a
new instance of the given checked exception type. |
static <V,X extends Exception> |
Futures.getChecked(Future<V> future,
Class<X> exceptionClass,
long timeout,
TimeUnit unit)
Returns the result of
Future.get(long, TimeUnit) , converting most
exceptions to a new instance of the given checked exception type. |
static ExecutorService |
MoreExecutors.getExitingExecutorService(ThreadPoolExecutor executor)
Converts the given ThreadPoolExecutor into an ExecutorService that exits
when the application is complete.
|
static ExecutorService |
MoreExecutors.getExitingExecutorService(ThreadPoolExecutor executor,
long terminationTimeout,
TimeUnit timeUnit)
Converts the given ThreadPoolExecutor into an ExecutorService that exits
when the application is complete.
|
static ScheduledExecutorService |
MoreExecutors.getExitingScheduledExecutorService(ScheduledThreadPoolExecutor executor)
Converts the given ThreadPoolExecutor into a ScheduledExecutorService that
exits when the application is complete.
|
static ScheduledExecutorService |
MoreExecutors.getExitingScheduledExecutorService(ScheduledThreadPoolExecutor executor,
long terminationTimeout,
TimeUnit timeUnit)
Converts the given ScheduledThreadPoolExecutor into a
ScheduledExecutorService that exits when the application is complete.
|
static <V> V |
Futures.getUnchecked(Future<V> future)
Returns the result of calling
Future.get() uninterruptibly on a
task known not to throw a checked exception. |
static <V> V |
Uninterruptibles.getUninterruptibly(Future<V> future,
long timeout,
TimeUnit unit)
Invokes
future. get(timeout, unit)
uninterruptibly. |
static <V> ListenableFuture<V> |
Futures.immediateCancelledFuture()
Creates a
ListenableFuture which is cancelled immediately upon
construction, so that isCancelled() always returns true . |
static <V,X extends Exception> |
Futures.immediateCheckedFuture(V value)
Returns a
CheckedFuture which has its value set immediately upon
construction. |
static <V,X extends Exception> |
Futures.immediateFailedCheckedFuture(X exception)
Returns a
CheckedFuture which has an exception set immediately upon
construction. |
static <T> ImmutableList<ListenableFuture<T>> |
Futures.inCompletionOrder(Iterable<? extends ListenableFuture<? extends T>> futures)
Returns a list of delegate futures that correspond to the futures received in the order
that they complete.
|
static void |
Uninterruptibles.joinUninterruptibly(Thread toJoin)
Invokes
toJoin. join() uninterruptibly. |
static void |
Uninterruptibles.joinUninterruptibly(Thread toJoin,
long timeout,
TimeUnit unit)
Invokes
unit. timedJoin(toJoin, timeout) uninterruptibly. |
static <I,O> Future<O> |
Futures.lazyTransform(Future<I> input,
Function<? super I,? extends O> function)
Like
Futures.transform(ListenableFuture, Function) except that the
transformation function is invoked on each call to
get() on the returned future. |
static ListeningExecutorService |
MoreExecutors.listeningDecorator(ExecutorService delegate)
Creates an
ExecutorService whose submit and invokeAll methods submit ListenableFutureTask instances to the
given delegate executor. |
static ListeningScheduledExecutorService |
MoreExecutors.listeningDecorator(ScheduledExecutorService delegate)
Creates a
ScheduledExecutorService whose submit and invokeAll methods submit ListenableFutureTask instances to the
given delegate executor. |
static <V,X extends Exception> |
Futures.makeChecked(ListenableFuture<V> future,
Function<? super Exception,X> mapper)
Creates a
CheckedFuture out of a normal ListenableFuture and a Function
that maps from Exception instances into the appropriate checked type. |
static ListeningExecutorService |
MoreExecutors.newDirectExecutorService()
Creates an executor service that runs each task in the thread
that invokes
execute/submit , as in ThreadPoolExecutor.CallerRunsPolicy This
applies both to individually submitted tasks and to collections of tasks
submitted via invokeAll or invokeAny . |
static <V> ListenableFuture<V> |
Futures.nonCancellationPropagating(ListenableFuture<V> future)
Creates a new
ListenableFuture whose result is set from the
supplied future when it completes. |
static ThreadFactory |
MoreExecutors.platformThreadFactory()
Returns a default thread factory used to create new threads.
|
static <E> void |
Uninterruptibles.putUninterruptibly(BlockingQueue<E> queue,
E element)
Invokes
queue. put(element)
uninterruptibly. |
static ListeningExecutorService |
MoreExecutors.sameThreadExecutor()
Deprecated.
Use
MoreExecutors.directExecutor() if you only require an Executor and
MoreExecutors.newDirectExecutorService() if you need a ListeningExecutorService . This
method will be removed in August 2016. |
static boolean |
MoreExecutors.shutdownAndAwaitTermination(ExecutorService service,
long timeout,
TimeUnit unit)
Shuts down the given executor gradually, first disabling new submissions and later cancelling
existing tasks.
|
static void |
Uninterruptibles.sleepUninterruptibly(long sleepFor,
TimeUnit unit)
Invokes
unit. sleep(sleepFor)
uninterruptibly. |
static <E> E |
Uninterruptibles.takeUninterruptibly(BlockingQueue<E> queue)
Invokes
queue. take() uninterruptibly. |
static boolean |
Uninterruptibles.tryAcquireUninterruptibly(Semaphore semaphore,
int permits,
long timeout,
TimeUnit unit)
Invokes
semaphore. tryAcquire(permits, timeout, unit) uninterruptibly. |
static boolean |
Uninterruptibles.tryAcquireUninterruptibly(Semaphore semaphore,
long timeout,
TimeUnit unit)
Invokes
semaphore. tryAcquire(1, timeout, unit) uninterruptibly. |
static <V> ListenableFuture<V> |
Futures.withTimeout(ListenableFuture<V> delegate,
long time,
TimeUnit unit,
ScheduledExecutorService scheduledExecutor)
Returns a future that delegates to another but will finish early (via a
TimeoutException wrapped in an ExecutionException ) if the
specified duration expires. |
Copyright © 2010-2015. All Rights Reserved.