org.jclouds.concurrent

Class Futures

java.lang.Object

org.jclouds.concurrent.Futures

@Beta
public class Futures
extends Object

functions related to or replacing those in Futures

Author:

Adrian Cole

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Futures.FutureListener<T>
static class	Futures.LazyListenableFutureFunctionAdapter<I,O>
static class	Futures.ListenableFutureAdapter<T>

Constructor Summary

Constructors

Constructor and Description
Futures()

Method Summary

Methods

Modifier and Type	Method and Description
static <I,O> com.google.common.util.concurrent.ListenableFuture<O>	compose(Future<I> future, com.google.common.base.Function<? super I,? extends O> function, ExecutorService executorService) Just like Futures#compose except that we check the type of the executorService before creating the Future.
static <T> com.google.common.util.concurrent.ListenableFuture<T>	makeListenable(Future<T> future, ExecutorService executorService) Just like Futures#makeListenable except that we pass in an executorService.

Methods inherited from class java.lang.Object

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

Constructor Detail

Futures

public Futures()

Method Detail

compose

public static <I,O> com.google.common.util.concurrent.ListenableFuture<O> compose(Future<I> future,
                                                                  com.google.common.base.Function<? super I,? extends O> function,
                                                                  ExecutorService executorService)

Just like Futures#compose except that we check the type of the executorService before creating the Future. If we are single threaded, invoke the function lazy as opposed to chaining, so that we don't invoke get() early.

makeListenable

public static <T> com.google.common.util.concurrent.ListenableFuture<T> makeListenable(Future<T> future,
                                                                       ExecutorService executorService)

Just like Futures#makeListenable except that we pass in an executorService.

Temporary hack until http://code.google.com/p/guava-libraries/issues/detail?id=317 is fixed.