A C D E F G I L M N R S T U V

A

AbstractCheckedFuture<V,E extends java.lang.Exception> - Class in com.google.common.util.concurrent
A delegating wrapper around a ListenableFuture that adds support for the checkedGet() and checkedGet(long, TimeUnit) methods.
AbstractCheckedFuture(ListenableFuture<V>) - Constructor for class com.google.common.util.concurrent.AbstractCheckedFuture
Constructs an AbstractCheckedFuture that wraps a delegate.
AbstractExecutionThreadService - Class in com.google.common.util.concurrent
Base class for services that can implement AbstractExecutionThreadService.startUp(), AbstractExecutionThreadService.run() and AbstractExecutionThreadService.shutDown() methods.
AbstractExecutionThreadService() - Constructor for class com.google.common.util.concurrent.AbstractExecutionThreadService
 
AbstractFuture<V> - Class in com.google.common.util.concurrent
An abstract implementation of the Future interface.
AbstractFuture() - Constructor for class com.google.common.util.concurrent.AbstractFuture
 
AbstractIdleService - Class in com.google.common.util.concurrent
Base class for services that do not need a thread while "running" but may need one during startup and shutdown.
AbstractIdleService() - Constructor for class com.google.common.util.concurrent.AbstractIdleService
 
AbstractListenableFuture<V> - Class in com.google.common.util.concurrent
An abstract base implementation of the listener support provided by ListenableFuture.
AbstractListenableFuture() - Constructor for class com.google.common.util.concurrent.AbstractListenableFuture
 
AbstractService - Class in com.google.common.util.concurrent
Base class for implementing services that can handle AbstractService.doStart() and AbstractService.doStop() requests, responding to them with AbstractService.notifyStarted() and AbstractService.notifyStopped() callbacks.
AbstractService() - Constructor for class com.google.common.util.concurrent.AbstractService
 
add(Runnable, Executor) - Method in class com.google.common.util.concurrent.ExecutionList
Add the runnable/executor pair to the list of pairs to execute.
addDelayedShutdownHook(ExecutorService, long, TimeUnit) - Static method in class com.google.common.util.concurrent.Executors
Deprecated. use MoreExecutors.addDelayedShutdownHook( ExecutorService, long, TimeUnit).
addDelayedShutdownHook(ExecutorService, long, TimeUnit) - Static method in class com.google.common.util.concurrent.MoreExecutors
Add a shutdown hook to wait for thread completion in the given service.
addListener(Runnable, Executor) - Method in class com.google.common.util.concurrent.AbstractCheckedFuture
 
addListener(Runnable, Executor) - Method in class com.google.common.util.concurrent.AbstractListenableFuture
 
addListener(Runnable, Executor) - Method in interface com.google.common.util.concurrent.ListenableFuture
Adds a listener and executor to the ListenableFuture.
addListener(Runnable, Executor) - Method in class com.google.common.util.concurrent.ListenableFutureTask
 

C

Callables - Class in com.google.common.util.concurrent
Static utility methods pertaining to the Callable interface.
callWithTimeout(Callable<T>, long, TimeUnit, boolean) - Method in class com.google.common.util.concurrent.FakeTimeLimiter
 
callWithTimeout(Callable<T>, long, TimeUnit, boolean) - Method in class com.google.common.util.concurrent.SimpleTimeLimiter
 
callWithTimeout(Callable<T>, long, TimeUnit, boolean) - Method in interface com.google.common.util.concurrent.TimeLimiter
Invokes a specified Callable, timing out after the specified time limit.
cancel(boolean) - Method in class com.google.common.util.concurrent.AbstractCheckedFuture
 
cancel(boolean) - Method in class com.google.common.util.concurrent.AbstractFuture
 
cancel() - Method in class com.google.common.util.concurrent.AbstractFuture
Subclasses should invoke this method to mark the future as cancelled.
cancel(boolean) - Method in class com.google.common.util.concurrent.ForwardingFuture
 
cancel(boolean) - Method in class com.google.common.util.concurrent.ValueFuture
chain(ListenableFuture<I>, Function<? super I, ? extends ListenableFuture<? extends O>>) - Static method in class com.google.common.util.concurrent.Futures
Creates a new ListenableFuture that wraps another ListenableFuture.
chain(ListenableFuture<I>, Function<? super I, ? extends ListenableFuture<? extends O>>, Executor) - Static method in class com.google.common.util.concurrent.Futures
Creates a new ListenableFuture that wraps another ListenableFuture.
CheckedFuture<V,E extends java.lang.Exception> - Interface in com.google.common.util.concurrent
A CheckedFuture is an extension of Future that includes versions of the get methods that can throw a checked exception and allows listeners to be attached to the future.
checkedGet() - Method in class com.google.common.util.concurrent.AbstractCheckedFuture
 
checkedGet(long, TimeUnit) - Method in class com.google.common.util.concurrent.AbstractCheckedFuture
 
checkedGet() - Method in interface com.google.common.util.concurrent.CheckedFuture
Exception checking version of Future.get() that will translate InterruptedException, CancellationException and ExecutionException into application-specific exceptions.
checkedGet(long, TimeUnit) - Method in interface com.google.common.util.concurrent.CheckedFuture
Exception checking version of Future.get(long, TimeUnit) that will translate InterruptedException, CancellationException and ExecutionException into application-specific exceptions.
com.google.common.util.concurrent - package com.google.common.util.concurrent
Concurrency utilities.
compose(ListenableFuture<I>, Function<? super I, ? extends O>) - Static method in class com.google.common.util.concurrent.Futures
Creates a new ListenableFuture that wraps another ListenableFuture.
compose(ListenableFuture<I>, Function<? super I, ? extends O>, Executor) - Static method in class com.google.common.util.concurrent.Futures
Creates a new ListenableFuture that wraps another ListenableFuture.
compose(Future<I>, Function<? super I, ? extends O>) - Static method in class com.google.common.util.concurrent.Futures
Creates a new Future that wraps another Future.
create() - Static method in class com.google.common.util.concurrent.ValueFuture
Creates a new ValueFuture in the default state.

D

DaemonThreadFactory - Class in com.google.common.util.concurrent
Wraps another ThreadFactory, making all new threads daemon threads.
DaemonThreadFactory(ThreadFactory) - Constructor for class com.google.common.util.concurrent.DaemonThreadFactory
 
daemonThreadFactory() - Static method in class com.google.common.util.concurrent.Executors
Deprecated. use MoreExecutors.daemonThreadFactory().
daemonThreadFactory(ThreadFactory) - Static method in class com.google.common.util.concurrent.Executors
Deprecated. use MoreExecutors.daemonThreadFactory(ThreadFactory).
daemonThreadFactory() - Static method in class com.google.common.util.concurrent.MoreExecutors
Returns a ThreadFactory which creates daemon threads.
daemonThreadFactory(ThreadFactory) - Static method in class com.google.common.util.concurrent.MoreExecutors
Wraps another ThreadFactory, making all new threads daemon threads.
DEFAULT_FACTORY - Static variable in class com.google.common.util.concurrent.NamingThreadFactory
 
delegate - Variable in class com.google.common.util.concurrent.AbstractCheckedFuture
The delegate, used to pass along all our methods.
delegate() - Method in class com.google.common.util.concurrent.ForwardingFuture
 
delegate() - Method in class com.google.common.util.concurrent.ForwardingService
 
done() - Method in class com.google.common.util.concurrent.AbstractFuture
 
done() - Method in class com.google.common.util.concurrent.AbstractListenableFuture
 
done() - Method in class com.google.common.util.concurrent.ListenableFutureTask
 
doStart() - Method in class com.google.common.util.concurrent.AbstractService
This method is called by AbstractService.start() to initiate service startup.
doStop() - Method in class com.google.common.util.concurrent.AbstractService
This method should be used to initiate service shutdown.

E

ExecutionList - Class in com.google.common.util.concurrent
A list of (Runnable, Executor) pairs that guarantees that every Runnable that is added using the add method will be executed in its associated Executor after ExecutionList.run() is called.
ExecutionList() - Constructor for class com.google.common.util.concurrent.ExecutionList
 
executor() - Method in class com.google.common.util.concurrent.AbstractExecutionThreadService
Returns the Executor that will be used to run this service.
executor(Service.State) - Method in class com.google.common.util.concurrent.AbstractIdleService
Returns the Executor that will be used to run this service.
Executors - Class in com.google.common.util.concurrent
Deprecated. use MoreExecutors

F

FakeTimeLimiter - Class in com.google.common.util.concurrent
A TimeLimiter implementation which actually does not attempt to limit time at all.
FakeTimeLimiter() - Constructor for class com.google.common.util.concurrent.FakeTimeLimiter
 
ForwardingFuture<V> - Class in com.google.common.util.concurrent
A Future which forwards all its method calls to another future.
ForwardingFuture() - Constructor for class com.google.common.util.concurrent.ForwardingFuture
 
ForwardingService - Class in com.google.common.util.concurrent
A Service that forwards all method calls to another service.
ForwardingService() - Constructor for class com.google.common.util.concurrent.ForwardingService
 
Futures - Class in com.google.common.util.concurrent
Static utility methods pertaining to the Future interface.

G

get() - Method in class com.google.common.util.concurrent.AbstractCheckedFuture
 
get(long, TimeUnit) - Method in class com.google.common.util.concurrent.AbstractCheckedFuture
 
get(long, TimeUnit) - Method in class com.google.common.util.concurrent.AbstractFuture
 
get() - Method in class com.google.common.util.concurrent.AbstractFuture
 
get() - Method in class com.google.common.util.concurrent.ForwardingFuture
 
get(long, TimeUnit) - Method in class com.google.common.util.concurrent.ForwardingFuture
 
get() - Method in interface com.google.common.util.concurrent.UninterruptibleFuture
 
get(long, TimeUnit) - Method in interface com.google.common.util.concurrent.UninterruptibleFuture
 
getExitingExecutorService(ThreadPoolExecutor, long, TimeUnit) - Static method in class com.google.common.util.concurrent.Executors
Deprecated. use MoreExecutors.getExitingExecutorService( ThreadPoolExecutor, long, TimeUnit).
getExitingExecutorService(ThreadPoolExecutor) - Static method in class com.google.common.util.concurrent.Executors
Deprecated. use MoreExecutors.getExitingExecutorService( ThreadPoolExecutor).
getExitingExecutorService(ThreadPoolExecutor, long, TimeUnit) - Static method in class com.google.common.util.concurrent.MoreExecutors
Converts the given ThreadPoolExecutor into an ExecutorService that exits when the application is complete.
getExitingExecutorService(ThreadPoolExecutor) - Static method in class com.google.common.util.concurrent.MoreExecutors
Converts the given ThreadPoolExecutor into an ExecutorService that exits when the application is complete.
getExitingScheduledExecutorService(ScheduledThreadPoolExecutor, long, TimeUnit) - Static method in class com.google.common.util.concurrent.Executors
Deprecated. use MoreExecutors.getExitingScheduledExecutorService( ScheduledThreadPoolExecutor, long, TimeUnit).
getExitingScheduledExecutorService(ScheduledThreadPoolExecutor) - Static method in class com.google.common.util.concurrent.Executors
Deprecated. use MoreExecutors.getExitingScheduledExecutorService( ScheduledThreadPoolExecutor).
getExitingScheduledExecutorService(ScheduledThreadPoolExecutor, long, TimeUnit) - Static method in class com.google.common.util.concurrent.MoreExecutors
Converts the given ScheduledThreadPoolExecutor into a ScheduledExecutorService that exits when the application is complete.
getExitingScheduledExecutorService(ScheduledThreadPoolExecutor) - Static method in class com.google.common.util.concurrent.MoreExecutors
Converts the given ThreadPoolExecutor into a ScheduledExecutorService that exits when the application is complete.

I

immediateCheckedFuture(T) - Static method in class com.google.common.util.concurrent.Futures
Creates a CheckedFuture which has its value set immediately upon construction.
immediateFailedCheckedFuture(E) - Static method in class com.google.common.util.concurrent.Futures
Creates a CheckedFuture which has an exception set immediately upon construction.
immediateFailedFuture(Throwable) - Static method in class com.google.common.util.concurrent.Futures
Creates a ListenableFuture which has an exception set immediately upon construction.
immediateFuture(T) - Static method in class com.google.common.util.concurrent.Futures
Creates a ListenableFuture which has its value set immediately upon construction.
isCancelled() - Method in class com.google.common.util.concurrent.AbstractCheckedFuture
 
isCancelled() - Method in class com.google.common.util.concurrent.AbstractFuture
 
isCancelled() - Method in class com.google.common.util.concurrent.ForwardingFuture
 
isDone() - Method in class com.google.common.util.concurrent.AbstractCheckedFuture
 
isDone() - Method in class com.google.common.util.concurrent.AbstractFuture
 
isDone() - Method in class com.google.common.util.concurrent.ForwardingFuture
 
isRunning() - Method in class com.google.common.util.concurrent.AbstractExecutionThreadService
 
isRunning() - Method in class com.google.common.util.concurrent.AbstractIdleService
 
isRunning() - Method in class com.google.common.util.concurrent.AbstractService
 
isRunning() - Method in class com.google.common.util.concurrent.ForwardingService
 

L

ListenableFuture<V> - Interface in com.google.common.util.concurrent
This interface defines a future that has listeners attached to it, which is useful for asynchronous workflows.
ListenableFutureTask<V> - Class in com.google.common.util.concurrent
A FutureTask that also implements the ListenableFuture interface.
ListenableFutureTask(Callable<V>) - Constructor for class com.google.common.util.concurrent.ListenableFutureTask
Creates a ListenableFutureTask that will upon running, execute the given Callable.
ListenableFutureTask(Runnable, V) - Constructor for class com.google.common.util.concurrent.ListenableFutureTask
Creates a ListenableFutureTask that will upon running, execute the given Runnable, and arrange that get will return the given result on successful completion.

M

makeChecked(Future<T>, Function<Exception, E>) - Static method in class com.google.common.util.concurrent.Futures
Creates a CheckedFuture out of a normal Future and a Function that maps from Exception instances into the appropriate checked type.
makeListenable(Future<T>) - Static method in class com.google.common.util.concurrent.Futures
Creates a ListenableFuture out of a normal Future.
makeUninterruptible(Future<V>) - Static method in class com.google.common.util.concurrent.Futures
Returns an uninterruptible view of a Future.
mapException(Exception) - Method in class com.google.common.util.concurrent.AbstractCheckedFuture
Translate from an InterruptedException, CancellationException or ExecutionException to an exception of type E.
MoreExecutors - Class in com.google.common.util.concurrent
Factory and utility methods for Executor, ExecutorService, and ThreadFactory.

N

NamingThreadFactory - Class in com.google.common.util.concurrent
A ThreadFactory which decorates another ThreadFactory to set a name on each thread created.
NamingThreadFactory(String) - Constructor for class com.google.common.util.concurrent.NamingThreadFactory
Creates a new factory that delegates to the default thread factory for thread creation, then uses format to construct a name for the new thread.
NamingThreadFactory(String, ThreadFactory) - Constructor for class com.google.common.util.concurrent.NamingThreadFactory
Creates a new factory that delegates to backingFactory for thread creation, then uses format to construct a name for the new thread.
newProxy(T, Class<T>, long, TimeUnit) - Method in class com.google.common.util.concurrent.FakeTimeLimiter
 
newProxy(T, Class<T>, long, TimeUnit) - Method in class com.google.common.util.concurrent.SimpleTimeLimiter
 
newProxy(T, Class<T>, long, TimeUnit) - Method in interface com.google.common.util.concurrent.TimeLimiter
Returns an instance of interfaceType that delegates all method calls to the target object, enforcing the specified time limit on each call.
newThread(Runnable) - Method in class com.google.common.util.concurrent.DaemonThreadFactory
 
newThread(Runnable) - Method in class com.google.common.util.concurrent.NamingThreadFactory
 
notifyFailed(Throwable) - Method in class com.google.common.util.concurrent.AbstractService
Invoke this method to transition the service to the Service.State.FAILED.
notifyStarted() - Method in class com.google.common.util.concurrent.AbstractService
Implementing classes should invoke this method once their service has started.
notifyStopped() - Method in class com.google.common.util.concurrent.AbstractService
Implementing classes should invoke this method once their service has stopped.

R

returning(T) - Static method in class com.google.common.util.concurrent.Callables
Creates a Callable which immediately returns a preset value each time it is called.
run() - Method in class com.google.common.util.concurrent.AbstractExecutionThreadService
Run the service.
run() - Method in class com.google.common.util.concurrent.ExecutionList
Runs this execution list, executing all pairs in the order they were added.

S

sameThreadExecutor() - Static method in class com.google.common.util.concurrent.Executors
Deprecated. use MoreExecutors.sameThreadExecutor().
sameThreadExecutor() - Static method in class com.google.common.util.concurrent.MoreExecutors
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.
set(V) - Method in class com.google.common.util.concurrent.AbstractFuture
Subclasses should invoke this method to set the result of the computation to value.
set(V) - Method in class com.google.common.util.concurrent.ValueFuture
Sets the value of this future.
setException(Throwable) - Method in class com.google.common.util.concurrent.AbstractFuture
Subclasses should invoke this method to set the result of the computation to an error, throwable.
setException(Throwable) - Method in class com.google.common.util.concurrent.ValueFuture
Sets the future to having failed with the given exception.
shutDown() - Method in class com.google.common.util.concurrent.AbstractExecutionThreadService
Stop the service.
shutDown() - Method in class com.google.common.util.concurrent.AbstractIdleService
Stop the service.
SimpleTimeLimiter - Class in com.google.common.util.concurrent
A TimeLimiter that runs method calls in the background using an ExecutorService.
SimpleTimeLimiter(ExecutorService) - Constructor for class com.google.common.util.concurrent.SimpleTimeLimiter
Constructs a TimeLimiter instance using the given executor service to execute proxied method calls.
SimpleTimeLimiter() - Constructor for class com.google.common.util.concurrent.SimpleTimeLimiter
Constructs a TimeLimiter instance using a Executors.newCachedThreadPool() to execute proxied method calls.
start() - Method in class com.google.common.util.concurrent.AbstractExecutionThreadService
 
start() - Method in class com.google.common.util.concurrent.AbstractIdleService
 
start() - Method in class com.google.common.util.concurrent.AbstractService
 
start() - Method in class com.google.common.util.concurrent.ForwardingService
 
startAndWait() - Method in class com.google.common.util.concurrent.AbstractExecutionThreadService
 
startAndWait() - Method in class com.google.common.util.concurrent.AbstractIdleService
 
startAndWait() - Method in class com.google.common.util.concurrent.AbstractService
 
startAndWait() - Method in class com.google.common.util.concurrent.ForwardingService
 
startUp() - Method in class com.google.common.util.concurrent.AbstractExecutionThreadService
Start the service.
startUp() - Method in class com.google.common.util.concurrent.AbstractIdleService
Start the service.
state() - Method in class com.google.common.util.concurrent.AbstractExecutionThreadService
 
state() - Method in class com.google.common.util.concurrent.AbstractIdleService
 
state() - Method in class com.google.common.util.concurrent.AbstractService
 
state() - Method in class com.google.common.util.concurrent.ForwardingService
 
stop() - Method in class com.google.common.util.concurrent.AbstractExecutionThreadService
 
stop() - Method in class com.google.common.util.concurrent.AbstractIdleService
 
stop() - Method in class com.google.common.util.concurrent.AbstractService
 
stop() - Method in class com.google.common.util.concurrent.ForwardingService
 
stopAndWait() - Method in class com.google.common.util.concurrent.AbstractExecutionThreadService
 
stopAndWait() - Method in class com.google.common.util.concurrent.AbstractIdleService
 
stopAndWait() - Method in class com.google.common.util.concurrent.AbstractService
 
stopAndWait() - Method in class com.google.common.util.concurrent.ForwardingService
 

T

TimeLimiter - Interface in com.google.common.util.concurrent
Produces proxies that impose a time limit on method calls to the proxied object.
toString() - Method in class com.google.common.util.concurrent.AbstractExecutionThreadService
 
toString() - Method in class com.google.common.util.concurrent.AbstractIdleService
 
toString() - Method in class com.google.common.util.concurrent.AbstractService
 
triggerShutdown() - Method in class com.google.common.util.concurrent.AbstractExecutionThreadService
Invoked to request the service to stop.

U

UncheckedTimeoutException - Exception in com.google.common.util.concurrent
Unchecked version of TimeoutException.
UncheckedTimeoutException() - Constructor for exception com.google.common.util.concurrent.UncheckedTimeoutException
 
UncheckedTimeoutException(String) - Constructor for exception com.google.common.util.concurrent.UncheckedTimeoutException
 
UncheckedTimeoutException(Throwable) - Constructor for exception com.google.common.util.concurrent.UncheckedTimeoutException
 
UncheckedTimeoutException(String, Throwable) - Constructor for exception com.google.common.util.concurrent.UncheckedTimeoutException
 
UninterruptibleFuture<V> - Interface in com.google.common.util.concurrent
A Future whose get calls cannot be interrupted.

V

ValueFuture<V> - Class in com.google.common.util.concurrent
A simple ListenableFuture that holds a value or an exception.

A C D E F G I L M N R S T U V

Copyright © 2010 Google. All Rights Reserved.