前提
オラクルのページの下記の記述が再現できなくて困っています。
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 コメント