現在Java,Eclipse,Java1.8でCompletabelFutureによる非同期処理を勉強しています。
以下のサイトにある次のコードを実装したのですが、コンソール出力されません。
なぜでしょうか?(サイト上ではコンソール出力されると書いているのですが)
CompletableFutureの公式ドキュメントを読んでも分からないので Java逆引きレシピを片手に理解する
public class CompletableFutureTest {
public static void main(String[] args) throws InterruptedException, ExecutionException {
CompletableFuture<String> future1 = CompletableFuture.supplyAsync(
() -> {
// 時間のかかる処理
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
return "java1";
});
// thenApplyの場合
future1
.thenApply(
new Function<String, String>() {
@Override
public String apply(String res) {
return res; // resには、future1のreturnで定義した「java1」が入っている
}
})
.thenApply(
res -> {
return res; // resには1回目のthenApplyの戻り値の「java1」が入っている
})
.thenAccept(
new Consumer<String>() {
@Override
public void accept(String res) {
System.out.println(res); // resには2回目のthenApplyの戻り値の「java1」が入っており、コンソールに出力される
}
});
}
}
ちなみにThread.sleep(1000);をThread.sleep(1);のように短くしたり、コメントアウトするとコンソール出力されます。動きとして、1秒後に返される戻り値を待てずにthenApply以降の処理が実行されているのかなと思います。
thenApply自体は前の処理の完了は待たないのでしょうか?「このステージが正常に完了したときに、このステージの結果を指定された関数への引数に設定して実行される新しいCompletionStageを返す。」だけであって。すなわち次の処理が同期処理になるだけでしょうか?
またもしそうだとした場合、著者の方はsleep処理を入れたと予想できますでしょうか?まるで1秒待ってから次の処理が実行されるようなリードですが。
もしわかる方がいればよろしくお願いいたします。