導入: なぜFutureが必要なのか？
Javaで重い処理（データベースへのアクセスや外部APIの呼び出しなど）を行う際、そのまま実行すると画面がフリーズしたり、全体の処理が止まったりします。これを解決するのが「非同期処理」です。非同期処理を行うと、メインの処理とは別にバックグラウンドでタスクを実行できます。そのバックグラウンドで動いているタスクの結果を、後から受け取ったり、状態を確認したりするために使うのがFutureインターフェースです。
基礎知識: Futureとは何か
Futureは「将来の結果」を保持するための入れ物です。
・get(): タスクの完了を待ち、結果を受け取ります。
・cancel(boolean mayInterruptIfRunning): 実行中のタスクをキャンセルします。
・isDone(): タスクが完了しているか（正常終了、例外終了、キャンセルいずれか）を確認します。
・isCancelled(): タスクがキャンセルされたかどうかを確認します。
これらを理解することで、非同期処理の制御がぐっと楽になります。
実装/解決策: ExecutorServiceでの活用
非同期処理を開始するには、スレッドを管理するExecutorServiceを使うのが一般的です。タスクを投入（submit）すると、戻り値としてFutureオブジェクトが返されます。これを使って、タスクの進捗を監視したり、結果を回収したりします。
サンプルプログラム: Futureを使った非同期処理
以下は、バックグラウンドで数値計算を行い、その結果をFuture経由で取得するコードです。
import java.util.concurrent.;
public class FutureSample {
public static void main(String[] args) {
// スレッドプールを作成
ExecutorService executor = Executors.newSingleThreadExecutor();
// 非同期タスクの投入
Future future = executor.submit(() -> {
Thread.sleep(2000); // 2秒かかる重い処理をシミュレート
return 100 + 200;
});
System.out.println("タスク実行中...");
try {
// isDoneで完了を確認しながら待つ
while (!future.isDone()) {
System.out.println("まだ計算中...");
Thread.sleep(500);
}
// 結果を取得（getはタスクが終わるまで待機する）
Integer result = future.get();
System.out.println("計算結果: " + result);
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
} finally {
// スレッドプールを終了させる（重要）
executor.shutdown();
}
}
}
応用・注意点: 現場でのポイント
1. get()のタイムアウト: future.get(5, TimeUnit.SECONDS)のように時間を指定しましょう。無限に待ち続けると、システムがハングアップする原因になります。
2. 例外処理: Futureのget()は、タスク内で発生した例外をExecutionExceptionとして投げます。エラーハンドリングを忘れないようにしてください。
3. 最新技術へのアンテナ: 近年のJavaでは、CompletableFutureがより柔軟な非同期処理を可能にしています。また、Java 21からのVirtual ThreadsやStructured Concurrencyを使うと、Futureを直接操作するよりもさらに効率的で可読性の高いコードが書けます。まずはFutureで「非同期の感覚」を掴み、その後に最新機能へステップアップすることをおすすめします。
コメント