Guava - 并行编程Futures详解

Guava provides many useful extensions for Java parallel programming Future, mainly through the ListenableFuture interface, and with the help of Futures static extensions.

ListenableFuture, which inherits from Future, allows us to add callback functions to return values or methods immediately after the thread operation is completed or the method execution is completed.

Add callback functions to ListenableFuture:

Futures.addCallback(ListenableFuture<V>, FutureCallback<V>, Executor)

Among them, FutureCallback is an interface that includes onSuccess(V), onFailure(Throwable).

Use as follows:

Futures.addCallback(ListenableFuture, new FutureCallback<Object>() {
  public void onSuccess(Object result) {
    System.out.printf("onSuccess with: %s%n", result);
  }
  public void onFailure(Throwable thrown) {
    System.out.printf("onFailure %s%n", thrown.getMessage());
  }
});

At the same time, Guava provides many useful extensions for Future extensions, mainly through the ListenableFuture interface, and with the help of Futures static extensions.

1. transform: Transforms the return value of ListenableFuture.
2. allAsList: Merges multiple ListenableFutures, returning a List object composed of multiple Future return values when all Futures are successful. Note: When one of the Futures fails or is cancelled, it will enter failure or cancellation.
3. successfulAsList: Similar to allAsList, the only difference is that for failed or cancelled Future return values, null is used instead. It will not enter the failure or cancellation process.
4. immediateFuture/immediateCancelledFuture: Immediately returns a ListenableFuture with a pending value to return.
5. makeChecked: Convert ListenableFuture to CheckedFuture. CheckedFuture is a ListenableFuture that includes multiple versions of the get method, with method declarations that throw checked exceptions. This makes it easier to create a Future that can throw exceptions in the execution logic.
6. JdkFutureAdapters.listenInPoolThread(future): guava offre également une interface de fonction pour convertir un JDK Future en ListenableFuture.
   

Ci-dessous se trouve un exemple de test pour Future :

@Test
public void should_test_furture() throws Exception {
  ListeningExecutorService service = MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(10));
  ListenableFuture future1 = service.submit(new Callable<Integer>() {
    public Integer call() throws InterruptedException {
      Thread.sleep(1000);
      System.out.println("call future 1.");
      return 1;
    }
  });
  ListenableFuture future2 = service.submit(new Callable<Integer>() {
    public Integer call() throws InterruptedException {
      Thread.sleep(1000);
      System.out.println("call future 2.");
  //    throw new RuntimeException("----call future 2.");
      return 2;
    }
  });
  final ListenableFuture allFutures = Futures.allAsList(future1, future2);
  final ListenableFuture transform = Futures.transform(allFutures, new AsyncFunction<List<Integer>, Boolean>() {
    @Override
    public ListenableFuture apply(List<Integer> results) throws Exception {
      return Futures.immediateFuture(String.format("success future:%d", results.size()));
    }
  });
  Futures.addCallback(transform, new FutureCallback<Object>() {
    public void onSuccess(Object result) {
      System.out.println(result.getClass());
      System.out.printf("success with: %s%n", result);
    }
    public void onFailure(Throwable thrown) {
      System.out.printf("onFailure%s%n", thrown.getMessage());
    }
  });
  System.out.println(transform.get());
}

Page d'accueil des documents officiels :https://awk.so/@code.google.com!/p/guava-bibliothèques/wiki/ListenableFutureExplained

Voici la présentation de Guava - Rassemblement de documents sur la programmation par lots Futures, continuerons à compléter les documents pertinents, merci de votre soutien à ce site !

Déclaration : le contenu de cet article est issu du réseau, et appartient à ses auteurs respectifs. Le contenu est fourni par les utilisateurs d'Internet de manière spontanée et auto-publiée. Ce site n'appartient pas à lui, n'a pas été édité par l'homme, et n'assume aucune responsabilité juridique. Si vous trouvez du contenu présumé violer les droits d'auteur, n'hésitez pas à envoyer un e-mail à : notice#oldtoolbag.com (veuillez remplacer # par @ lors de l'envoi d'un e-mail pour signaler des violations, et fournissez des preuves pertinentes. Une fois vérifié, ce site supprimera immédiatement le contenu présumé enfreindre les droits d'auteur.