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

Question

前提

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

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

問題・課題

• 下記のメソッド allOfOff() において、なぜ CompletableFuture.allOf(a, b, c).join(); が無い場合でも一番時間のかかるbの表示が最後にならないのでしょうか。
• CompletableFuture.allOf(a, b, c).join(); がある場合と無い場合の動作結果の違いを生じさせることは可能でしょうか。

該当のソースコード

import java.util.concurrent.CompletableFuture;
import java.util.function.Supplier;

public class Main {
  public static void main(String[] args) throws Exception {
    allOfOn();
    allOfOff();
  }

  private static Supplier<String> createSupplier(String s, long ms) {
    return () -> {
      try {
        Thread.sleep(ms);
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
      return s;
    };
  }

  private static void allOfOn() {
    long startMs = System.currentTimeMillis();

    var a = CompletableFuture.supplyAsync(createSupplier("aです。", 100));
    var b = CompletableFuture.supplyAsync(createSupplier("bです。", 200));
    var c = CompletableFuture.supplyAsync(createSupplier("cです。", 150));

    // これがあってもなくても同じなのが不思議
    CompletableFuture.allOf(a, b, c).join();

    System.out.println(a.join());
    System.out.println(b.join());
    System.out.println(c.join());

    var lapseMs = System.currentTimeMillis() - startMs;
    System.out.println(lapseMs + "ミリ秒");
  }

  private static void allOfOff() {
    long startMs = System.currentTimeMillis();

    var a = CompletableFuture.supplyAsync(createSupplier("aです。", 100));
    var b = CompletableFuture.supplyAsync(createSupplier("bです。", 200));
    var c = CompletableFuture.supplyAsync(createSupplier("cです。", 150));

    // これがあってもなくても同じなのが不思議
    // CompletableFuture.allOf(a, b, c).join();

    System.out.println(a.join());
    System.out.println(b.join());
    System.out.println(c.join());

    var lapseMs = System.currentTimeMillis() - startMs;
    System.out.println(lapseMs + "ミリ秒");
  }
}

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

aです。
bです。
cです。
200ミリ秒
aです。
bです。
cです。
201ミリ秒

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

動作環境

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

手元のJavaのバージョン

bash-4.2# javac -version
javac 11.0.18

Answer 1

  private static Supplier<String> createSupplier(String s, long ms) {
    return () -> {
      try {
        Thread.sleep(ms);
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
      System.out.println("------" + s); // ←コレ追加
      return s;
    };
  }

実行結果

------aです。
------cです。
------bです。//*** a,b,c全部完了するまで待ってくれてる
aです。
bです。
cです。
222ミリ秒
------aです。
aです。// ***完了を待たずに動き始めた
------cです。
------bです。
bです。
cです。
201ミリ秒

Comments

[yuzunoha123]

ありがとうございます！！！

Answer 2

a, b, c がどの順番で終わろうが、 a, b, c の順に表示しているのですから、そうならないほうがおかしいでしょう。

動作結果の違いを生じさせる

allOf を含む各 join の前後で時間でも出してみては如何でしょうか。