Java 9におけるCompletableFuture APIの主な改善点を徹底解説

CompletableFuture APIは、Javaにおける非同期（asynchronous）プログラミングのための仕組みです。このAPIを使うことで、main()スレッドとは別のスレッド上でタスクを実行し、その進行状況・完了・失敗をmain()スレッドへ通知できるため、ノンブロッキングなコードを記述できます。

Java 9では、このCompletableFuture APIに対して以下の3つの改善が導入されました。

• タイムアウトと遅延のサポート
• サブクラス化サポートの強化
• 新しいファクトリメソッドの追加

1. タイムアウトと遅延のサポート

orTimeout() メソッド

public CompletableFuture<T> orTimeout(long timeout, TimeUnit unit)

このメソッドは、タスクが指定された時間内に完了しなかった場合に、TimeoutExceptionを発生させて処理を終了させるために使用します。長時間応答しない非同期処理を安全に打ち切れるため、堅牢なアプリケーション設計に役立ちます。

completeOnTimeout() メソッド

public CompletableFuture<T> completeOnTimeout(T value, long timeout, TimeUnit unit)

このメソッドは、指定された時間内に処理が完了しなかった場合に、引数で渡したデフォルト値を使ってCompletableFutureを完了させます。タイムアウト時でも例外ではなく代替値を返したいケースに便利です。

2. サブクラス化サポートの強化

defaultExecutor() メソッド

public Executor defaultExecutor()

このメソッドは、Executorが明示的に指定されていない非同期メソッドで使用されるデフォルトのExecutorを返します。サブクラスでオーバーライドすることにより、少なくとも1つの独立したスレッドを持つ独自のExecutorを提供できます。

newIncompleteFuture() メソッド

public <U> CompletableFuture<U> newIncompleteFuture()

このメソッドは、CompletionStageインターフェースの各メソッドが返すべき、新しい未完了状態のCompletableFutureインスタンスを生成します。これにより、サブクラス側で戻り値の型を柔軟に制御できるようになりました。

3. 新しいファクトリメソッド

completedFuture() メソッド

public static <U> CompletableFuture<U> completedFuture(U value)

このファクトリメソッドは、指定された値ですでに完了済みの状態となっている、新しいCompletableFutureを返します。

completedStage() メソッド

public static <U> CompletionStage<U> completedStage(U value)

このファクトリメソッドは、指定された値ですでに完了している新しいCompletionStageを返します。返されるオブジェクトはCompletionStageインターフェースに定義されたメソッドのみをサポートするため、実装の詳細を隠蔽した安全な戻り値として活用できます。

これらの改善により、Java 9以降のCompletableFutureは、タイムアウト制御やカスタマイズ性が大幅に向上し、より実用的な非同期処理の構築が可能になりました。