ListenableFuture Arayüzü

Giriş
Şu satırı dahil ederiz.

import com.google.common.util.concurrent.ListenableFuture;

Bu arayüzü elde etmek için şu executor kullanılır.

ListeningExecutorService pool = MoreExecutors.listeningDecorator(
  Executors.newFixedThreadPool(10));

ListenableFuture bitince kod çalıştırmak için FutureCallback kullanılır

constructor
Şöyle yaparız.

Runnable runnable = () -> {};

ListenableFuture<?> future = executor.submit(runnable);

get metodu
Şöyle yaparız.

ListenableFuture<List<T>> futureOfList = ...; 
List<T> responses;
try {
  responses = futureOfList.get(timeoutMillis, TimeUnit.MILLISECONDS);
} catch (TimeoutException e) {
  ...
}
return responses;