【Javaコード入門】Stream API_④Streamの終端処理 - アンドエンジニア

終端処理では、Stream内で加工／フィルターされた値を最終的に出力／集計します。Streamでは、中間処理の時点では処理をストックします。そして、終端処理が呼び出されたところでまとめて加工／フィルターなどを実施します（遅延処理）。その性質上、中間処理は省略可能ですが、終端処理は末尾で必ず呼び出さなければなりません。

要素を順に処理する – forEachメソッド

public void forEach(Consumer<? super T> action)
　T：要素の型
　action：個々の要素を処理するラムダ式

たとえば以下は、Streamの内容を順に出力する例です。

StreamForEach.java

package com.example.mynavi.streamapi;
import java.util.stream.Stream;
public class StreamForEach {
public static void main(String args) {
Stream.of("あいうえお", "かきくけこ", "さしすせそ")
.forEach(System.out::println);
}
}

▼

あいうえお
かきくけこ
さしすせそ

forEachメソッドは、「個々の要素を引数として受け取り、これを処理する（戻り値はなし）」ラムダ式を受け取ります。printlnメソッドは、引数をひとつ受け取り、戻り値がvoidなので、そのままforEachメソッドに渡せるわけです（メソッドそのものを渡す表現を、メソッド参照と呼びます）。

よって、サンプルの太字部分は以下のように書き換えても同じ意味です。

.forEach(s -> System.out.println(s));

Stream内の値が条件を満たすかを判定する – xxxxxMatchメソッド

public boolean anyMatch(Predicate<? super T> predicate)
public boolean allMatch(Predicate<? super T> predicate)
public boolean noneMatch(Predicate<? super T> predicate)
　T：要素の型
　predicate：条件式を表すラムダ式

anyMatchメソッドは条件式を満たす要素がひとつでもある場合、allMatchメソッドはすべての要素が条件式を満たす場合、そして、noneMatchメソッドはひとつも満たさない場合に、それぞれtrueを返します。

たとえば以下は、Stream内のすべての要素が5文字以上であるかを判定する例です。

StreamMatch.java

package com.example.mynavi.streamapi;
import java.util.stream.Stream;
public class StreamMatch {
public static void main(String args) {
System.out.println(
Stream.of("あかさか", "さくらぎちょう", "よよぎ")
.allMatch(v -> v.length() >= 5)
); // 結果：false
}
}

太字の部分をanyMatch／noneMatchに変更した場合には、それぞれ結果はtrue、falseとなります。

最初の要素だけを取得する – findFirstメソッド

public Optional<T> findFirst()
　T：要素の型

findFirstメソッドを利用することで、Streamから先頭の要素だけを取得できます。

streamFirst.java

package com.example.mynavi.streamapi;
import java.util.stream.Stream;
public class streamFirst {
public static void main(String args) {
System.out.println(
Stream.of("あかさか", "さくま", "あおし")
.filter(s -> s.startsWith("あ"))
.findFirst()
.orElse("×")
); // 結果：あかさか
}
}

findFirstメソッドの戻り値は、Optional型です。よって、値を取得するにはorElseなどのメソッドを介さなければなりません。

Streamの内容を集計する

public Optional<T> max(Comparator<? super T> comparator) … 最大値
public Optional<T> min(Comparator<? super T> comparator) … 最小値
public long count() … 個数
public OptionalDouble average() … 平均値
public int sum() … 合計値
　T：要素の型
　comparator：比較ルールを表すラムダ式

Streamの内容を集計するために、上のようなメソッドを利用できます。ただし、average／sumメソッドが利用できるのは、IntStreamなどの基本型Streamだけです。

たとえば以下は、これらのメソッドを使って数値型Streamの内容を集計する例です。

StreamSum.java