導入
Java 8で導入されたStream APIは、データ処理を宣言的かつ直感的に記述できる強力なツールです。中でも「forEach」は終端操作として頻繁に使用されますが、並列ストリーム（parallelStream）を扱う際、処理順序が保証されないという課題があります。本稿では、順序を維持するための「forEachOrdered」の重要性と、適切な使い分けについて解説します。
基礎知識
Javaのコレクションにおいて、forEachは各要素に対してアクションを実行するメソッドです。
forEach()は、並列ストリームを使用した場合、パフォーマンスを優先するために要素の処理順序が不定になります。一方、forEachOrdered()は、ストリームの元々の順序（Listのような順序付きコレクションであればその順序）を維持して処理を実行します。
並列処理はマルチコアCPUの恩恵を最大限に受けるための仕組みですが、処理の順序が重要でない場合にのみ適用すべきです。順序が重要なビジネスロジックでforEachを安易に使うと、バグの温床になります。
実装/解決策
順序の保持が必要な場合は、迷わずforEachOrderedを使用してください。ただし、forEachOrderedは並列ストリームにおいて、順序を守るために「ストリームの各要素を直列的に処理する制約」を加えるため、forEachと比較してパフォーマンスが低下する可能性があります。
「順序が必要か」「並列処理で速度を稼ぎたいか」のトレードオフを慎重に判断することが、シニアエンジニアとしての腕の見せ所です。
サンプルプログラム
以下のコードで、並列ストリーム実行時の挙動の違いを確認してください。
import java.util.Arrays;
import java.util.List;
public class StreamOrderExample {
public static void main(String[] args) {
List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);
System.out.println("--- forEach (順序保証なし) ---");
// 並列処理では実行するたびに順序が変わる可能性があります
numbers.parallelStream().forEach(n -> System.out.print(n + " "));
System.out.println("\n\n--- forEachOrdered (順序保証あり) ---");
// 並列処理でも元のリストの順序通りに出力されます
numbers.parallelStream().forEachOrdered(n -> System.out.print(n + " "));
}
}
応用・注意点
1. 副作用の回避: forEach内で外部の変数を変更する（いわゆる副作用）ことは、並列処理においてはスレッドセーフの問題を引き起こします。可能な限り、forEach内での変数の書き換えは避け、Collectors等を用いた集計処理を検討してください。
2. MapのforEach: MapでforEachを使う場合、Mapの実装（HashMap vs TreeMapなど）によって順序が異なります。Sequenced Collections（Java 21以降）を利用すれば、順序付きのコレクションをより安全に扱えるため、新しいプロジェクトでは積極的に採用しましょう。
3. パフォーマンスの判断: 順序が不要な大量データ処理であれば、迷わず並列ストリーム＋forEachを選択し、順序が必須であればforEachOrderedを使用する。この基準をチーム内で共有するだけで、デバッグの工数は劇的に減らせます。
コメント