com.google.common.util.concurrent

Class Futures.CombinerFuture<V>

java.lang.Object

java.util.concurrent.FutureTask<V>

com.google.common.util.concurrent.ListenableFutureTask<V>

com.google.common.util.concurrent.Futures.CombinerFuture<V>

All Implemented Interfaces:

ListenableFuture<V>, java.lang.Runnable, java.util.concurrent.Future<V>, java.util.concurrent.RunnableFuture<V>

Enclosing class:

Futures

private static final class Futures.CombinerFuture<V>
extends ListenableFutureTask<V>

Field Summary

Fields

Modifier and Type	Field and Description
(package private) ImmutableList<ListenableFuture<?>>	futures

Constructor Summary

Constructors

Constructor and Description
CombinerFuture(java.util.concurrent.Callable<V> callable, ImmutableList<ListenableFuture<?>> futures)

Method Summary

Modifier and Type	Method and Description
boolean	cancel(boolean mayInterruptIfRunning)
protected void	done() Internal implementation detail used to invoke the listeners.
protected void	setException(java.lang.Throwable t)

Methods inherited from class com.google.common.util.concurrent.ListenableFutureTask

addListener, create, create

Methods inherited from class java.util.concurrent.FutureTask

get, get, isCancelled, isDone, run, runAndReset, set

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.concurrent.Future

get, get, isCancelled, isDone

Field Detail

futures

ImmutableList<ListenableFuture<?>> futures

Constructor Detail

CombinerFuture

CombinerFuture(java.util.concurrent.Callable<V> callable,
               ImmutableList<ListenableFuture<?>> futures)

Method Detail

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface java.util.concurrent.Future<V>

Overrides:

cancel in class java.util.concurrent.FutureTask<V>

done

protected void done()

Description copied from class: ListenableFutureTask

Internal implementation detail used to invoke the listeners.

Overrides:

done in class ListenableFutureTask<V>

setException

protected void setException(java.lang.Throwable t)

Overrides:

setException in class java.util.concurrent.FutureTask<V>