CompletableFuture.allOf(a, b, c).join(); がある場合と無い場合の動作結果の違いを生じさせたい。

前提

オラクルのページの下記の記述が再現できなくて困っています。
https://docs.oracle.com/javase/jp/8/docs/api/java/util/concurrent/CompletableFuture.html

このメソッドの用途の1つは、CompletableFuture.allOf(c1, c2, c3).join();のように、プログラムを続行する前に一連の独立したCompletableFutureの完了を待機することです。

問題・課題

該当のソースコード

Java

1import java.util.concurrent.CompletableFuture;2import java.util.function.Supplier;3 4public class Main {5 public static void main(String[] args) throws Exception {6 allOfOn();7 allOfOff();8 }9 10 private static Supplier<String> createSupplier(String s, long ms) {11 return () -> {12 try {13 Thread.sleep(ms);14 } catch (InterruptedException e) {15 e.printStackTrace();16 }17 return s;18 };19 }20 21 private static void allOfOn() {22 long startMs = System.currentTimeMillis();23 24 var a = CompletableFuture.supplyAsync(createSupplier("aです。", 100));25 var b = CompletableFuture.supplyAsync(createSupplier("bです。", 200));26 var c = CompletableFuture.supplyAsync(createSupplier("cです。", 150));27 28 // これがあってもなくても同じなのが不思議29 CompletableFuture.allOf(a, b, c).join();30 31 System.out.println(a.join());32 System.out.println(b.join());33 System.out.println(c.join());34 35 var lapseMs = System.currentTimeMillis() - startMs;36 System.out.println(lapseMs + "ミリ秒");37 }38 39 private static void allOfOff() {40 long startMs = System.currentTimeMillis();41 42 var a = CompletableFuture.supplyAsync(createSupplier("aです。", 100));43 var b = CompletableFuture.supplyAsync(createSupplier("bです。", 200));44 var c = CompletableFuture.supplyAsync(createSupplier("cです。", 150));45 46 // これがあってもなくても同じなのが不思議47 // CompletableFuture.allOf(a, b, c).join();48 49 System.out.println(a.join());50 System.out.println(b.join());51 System.out.println(c.join());52 53 var lapseMs = System.currentTimeMillis() - startMs;54 System.out.println(lapseMs + "ミリ秒");55 }56}

該当のソースコードの実行結果

bash

1aです。 2bです。 3cです。 4200ミリ秒 5aです。 6bです。 7cです。 8201ミリ秒

補足情報(FW/ツールのバージョンなど)

動作環境

手元のJavaとpaiza.ioにて当該の挙動を確認しています。
https://paiza.io/projects/cvHXvQv0qM4pLd7falyxeg

手元のJavaのバージョン

bash-4.2# javac -version
javac 11.0.18

コメントを投稿

0 コメント