Java 8 - l'Appel de méthodes asynchrones en parallèle et de combiner leurs résultats

Je suis nouveau sur le Java 8 simultanéité des fonctionnalités telles que CompletableFuture et j'espère que vous pouvez aider à obtenir commencé avec la suite de cas d'utilisation.

Il ya un service appelé TimeConsumingServices qui fournit beaucoup de temps à des opérations qui j'aimerais exécuter en parallèle puisque tous sont indépendants.

interface TimeConsumingService {

  default String hello(String name) {
    System.out.println(System.currentTimeMillis() + " > hello " + name);
    return "Hello " + name;
  }
  default String planet(String name) {
    System.out.println(System.currentTimeMillis() + " > planet " + name);
    return "Planet: " + name;
  }
  default String echo(String name) {
    System.out.println(System.currentTimeMillis() + " > echo " + name);
    return name;
  }

  default byte[] convert(String hello, String planet, String echo) {
    StringBuilder sb = new StringBuilder();
    sb.append(hello);
    sb.append(planet);
    sb.append(echo);
    return sb.toString().getBytes();
  }
}

Jusqu'à présent j'ai mis en place l'exemple suivant et j'ai réussi à appeler les trois méthodes en parallèle. 

public class Runner implements TimeConsumingService {

  public static void main(String[] args) {
    new Runner().doStuffAsync();
  }

  public void doStuffAsync() {
    CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> this.hello("Friend"));
    CompletableFuture<String> future2 = CompletableFuture.supplyAsync(() -> this.planet("Earth"));
    CompletableFuture<String> future3 = CompletableFuture.supplyAsync(() -> this.echo("Where is my echo?"));

    CompletableFuture.allOf(future1, future2, future3).join();
  }
}

Est-il un moyen de collecter les valeurs de retour de chaque appel de service et appeler la méthode byte[]‘ convert(String, String, String)?

InformationsquelleAutor saw303 | 2017-02-28
  1. 10

    À combiner le résultat après avoir retourné tous vous pouvez faire quelque chose comme ceci

    CompletableFuture<byte[]> byteFuture = CompletableFuture.allOf(cf1, cf2, cf3)
                     .thenApplyAsync(aVoid -> convert(cf1.join(), cf2.join(), cf3.join()));
byte[] bytes = byteFuture.join();

    Cela permettra d'exécuter l'ensemble de vos contrats à terme, d'attendre qu'elles se terminent, puis dès qu'ils sont tous finis appelle votre convert méthode que vous mentionnez.

    InformationsquelleAutor Ash
  2. 4

    Rejoindre après, vous pouvez simplement get() valeurs de future1 comme: 

    String s1 = future1.get()

    et ainsi de suite

    • Mais si je l'appelle future1.get(); future2.get(); future3.get(); ils ne sont pas appelés en parallèle, n'est-ce pas?
    • Lorsque vous appelez future1.get (), puis vous obtenez juste déjà calculées résultat.
    • Oui l'obtention de résultats n'est pas appelé en parallèle, mais de toutes les méthodes seront calculées de manière asynchrone. Vous pouvez le vérifier avec l'ajout de TimeUnit.seconds(2).sleep(); après la méthode de participation. Vous verrez que System.out.println a été appelé avant que le sommeil.
    • Pensez à stocker votre Futures dans une Liste plutôt que comme des variables individuelles. Ensuite, vous pouvez faire une boucle à travers eux, à consommer les résultats.
    • Vous pouvez consulter mon ancienne question à propos de CompletableFuture et de la traiter avec stream stackoverflow.com/questions/41392286/...
    InformationsquelleAutor user2377971
  3. 1

    Vous pouvez les combiner à l'aide de thenCombine() méthode si il y a seulement 3 contrat à remplir:

    final CompletableFuture<byte[]> byteFuture = future1.thenCombine(future2, (t, u) -> {
    StringBuilder sb = new StringBuilder();
    sb.append(t);
    sb.append(u);
    return sb.toString();
}).thenCombine(future3, (t, u) -> {
    StringBuilder sb = new StringBuilder();
    sb.append(t);
    sb.append(u);
    return sb.toString();
}).thenApply(s -> s.getBytes());

try {
    final byte[] get = byteFuture.get();
} catch (InterruptedException | ExecutionException ex) {
}
    InformationsquelleAutor MBec