【Java学習｜初心者向け】Java 21の新機能！ `Executors.newVirtualThreadPerTaskExecutor()`で超並列処理を体験しよう

皆さん、こんにちは！Javaエンジニアの皆さん、日々のコーディングお疲れ様です。今回は、Java 21で導入された注目の新機能、`Executors.newVirtualThreadPerTaskExecutor()`について、初心者の方にも分かりやすく解説していきます。

なぜVirtual Threadsが重要なのか？

従来のJavaでは、並列処理を行う際、スレッドの生成・管理にコストがかかるという課題がありました。特に、大量のリクエストを同時に処理しようとすると、スレッド数がボトルネックとなり、パフォーマンスが低下してしまうことがありました。

`Executors.newVirtualThreadPerTaskExecutor()`は、この課題を解決するために登場した「仮想スレッド（Virtual Threads）」を利用するためのExecutorServiceを提供します。仮想スレッドは、OSのスレッドよりもはるかに軽量で、数百万個ものスレッドを同時に生成・管理することが可能です。これにより、従来のプラットフォームスレッドでは難しかった、大規模な並列処理や高負荷なI/O処理を、よりシンプルかつ効率的に実装できるようになります。

仮想スレッド（Virtual Threads）とは？

仮想スレッドは、Javaの実行時環境（JVM）が管理する軽量なスレッドです。プラットフォームスレッド（OSのスレッド）とは異なり、生成や破棄のコストが非常に低く、ブロックする操作（I/O待ちなど）が発生しても、プラットフォームスレッドを占有しません。ブロックが発生すると、JVMは別のタスクを実行するためにそのプラットフォームスレッドを再利用します。これにより、限られたプラットフォームスレッドリソースを最大限に活用し、スループットを大幅に向上させることができます。

`Executors.newVirtualThreadPerTaskExecutor()`の使い方

`Executors.newVirtualThreadPerTaskExecutor()`は、その名の通り、実行するタスクごとに新しい仮想スレッドを生成して実行するExecutorServiceを作成します。使い方は非常にシンプルです。

まず、`Executors`クラスの静的メソッドを呼び出すだけです。

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

public class VirtualThreadExample {

public static void main(String[] args) throws InterruptedException {
// 仮想スレッドをタスクごとに生成するExecutorServiceを作成
// Java 21以降で利用可能
ExecutorService virtualThreadExecutor = Executors.newVirtualThreadPerTaskExecutor();

System.out.println(“仮想スレッド処理を開始します…”);

// 10個のタスクを並列実行
for (int i = 0; i < 10; i++) { final int taskId = i; virtualThreadExecutor.submit(() -> {
String threadName = Thread.currentThread().getName();
System.out.println(“タスク ” + taskId + ” がスレッド ” + threadName + ” で実行中です。”);
try {
// 時間のかかる処理をシミュレート
TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
Thread.currentThread().interrupt(); // 中断された場合は割り込みフラグを立てる
System.err.println(“タスク ” + taskId + ” が中断されました。”);
}
System.out.println(“タスク ” + taskId + ” が完了しました。”);
});
}

// ExecutorServiceをシャットダウンし、全てのタスクが完了するのを待つ
virtualThreadExecutor.shutdown();
virtualThreadExecutor.awaitTermination(1, TimeUnit.MINUTES);

System.out.println(“全ての仮想スレッド処理が完了しました。”);
}
}

コードの解説:

1. `ExecutorService virtualThreadExecutor = Executors.newVirtualThreadPerTaskExecutor();`

ここで、仮想スレッドをタスクごとに生成するExecutorServiceを作成しています。`Executors.newVirtualThreadPerTaskExecutor()`メソッドが、この特別なExecutorServiceを返します。

2. `virtualThreadExecutor.submit(() -> { … });`

`submit()`メソッドにラムダ式（無名関数）を渡すことで、実行したい処理を定義しています。このラムダ式は、新しい仮想スレッド上で実行されます。

3. `String threadName = Thread.currentThread().getName();`

`Thread.currentThread().getName()`で、現在実行中のスレッドの名前を取得しています。仮想スレッドの場合、通常は `virtual-X` のような形式の名前になります。

4. `TimeUnit.SECONDS.sleep(1);`

ここでは、I/O待ちなどの時間のかかる処理をシミュレートしています。仮想スレッドは、このようなブロックする操作が発生しても、プラットフォームスレッドを解放するため、他のタスクの実行を妨げません。

5. `virtualThreadExecutor.shutdown();`

ExecutorServiceに対して、新しいタスクの受け付けを停止し、現在実行中またはキューに入っているタスクの完了を待つように指示します。

6. `virtualThreadExecutor.awaitTermination(1, TimeUnit.MINUTES);`

ExecutorServiceが完全にシャットダウンされるまで（最大1分間）、現在のスレッド（mainスレッド）を待機させます。

このコードを実行すると、各タスクがそれぞれ異なる仮想スレッドで実行され、短時間で完了していく様子が確認できるはずです。

応用と注意点

スレッドプールの代替: 従来の`Executors.newFixedThreadPool()`や`Executors.newCachedThreadPool()`の代わりに、よりシンプルかつ効率的に並列処理を実現したい場合に活用できます。
I/Oバウンドな処理との相性: ネットワーク通信やファイルI/Oなど、CPUをあまり使わずに待ち時間が発生する処理（I/Oバウンドな処理）で特に効果を発揮します。
ExecutorServiceのシャットダウン: 仮想スレッドもリソースであるため、使い終わったExecutorServiceは必ず`shutdown()`メソッドでシャットダウンし、リソースを解放しましょう。`awaitTermination()`と組み合わせることで、全ての処理が完了したことを確認してからアプリケーションを終了させることができます。
ExecutorServiceのライフサイクル管理: アプリケーション全体で単一のExecutorServiceを管理し、必要に応じてタスクを投入していくのが一般的です。`Executors.newVirtualThreadPerTaskExecutor()`は、そのための手軽な方法を提供してくれます。
Structured Concurrencyとの連携: Java 21ではStructured Concurrency APIも導入されており、仮想スレッドと組み合わせて使うことで、関連する複数のタスクのライフサイクルをより安全かつ効率的に管理できるようになります。これは、より高度な並行処理パターンを実装する際に非常に役立ちます。

`Executors.newVirtualThreadPerTaskExecutor()`は、Javaの並行処理の世界を大きく変える可能性を秘めた機能です。ぜひ皆さんも、この新しいAPIを使って、よりシンプルでパワフルな並列処理を体験してみてください！