Java SE8 Streamについて

Question

Java SE8 Goldの勉強をしているのですが、問題を解いていて疑問に思ったことがあります。
ある問題では、次のコートについて、「コンパイルは成功するが、実行するとハングとなる」が正解とされています。

Predicate<? super String> p = s -> s.startsWith("g");
Stream<String> st1 = Stream.generate(() -> "orange");
Stream<String> st2 = Stream.generate(() -> "gold"));
System.out.print(st1.anyMatch(p) + " ");
System.out.println(st2.allMatch(p));

理由は、generate()メソッドはlimit()などで終了しないと無限にストリームが生成されるためとのことです。

しかし、別の問題では、次のコードは「実行時エラー（IllegalStateException例外がスロー）」が正解とされています。

Predicate<? super String> f = s -> s.length() > 3;
Stream<String> stream = Stream.iterate("x", s -> s + s);
boolean a = stream.noneMatch(f);
boolean b = stream.anyMatch(f);
System.out.println(a + " " + b);

理由は、同じStreamで終端操作を２回行っているためとのことです。
このコードについても、１つ目のコード同様、iterate()メソッドは無限にストリームを生成するため、「コンパイルは成功するが、実行するとハング」するが正解となるかと思います。（選択肢にもあります）。

違いが分かりません。素人のため、すごく単純な勘違いがあるかもしれませんが、どうかご教授お願い致します。

Comments

[swordone]

1つ目のコードの最後の行をまちがえていませんか？

Answer 1

実際にそのコードを実行させてみるとわかることだと思われます。
で、それでどうなったんでしょうか

Comments

[退会済みユーザー]

早速回答いただきありがとうございます。
実際コードを実行してみると、問題集の回答どおりとなり、２つ目のコードはハングしませんでした。

ただ、なぜハングしないかはわかりません。

[y_waiwai]

ならその回答が正解だということですね

[退会済みユーザー]

回答ありがとうございます。
ハングについても実行時エラーであると勘違いしておりました。

Answer 2

anyMatch、allMatch、noneMatchは、評価が定まるまでストリームを舐めます。

#####boolean anyMatch​(Predicate<? super T> predicate)

このストリームのいずれかの要素が指定された述語に一致するかどうかを返します。 **すべての要素で述語を評価するとは限りません(結果を決定するのに必要でない場合)。 **ストリームが空の場合、falseが返され、述語は評価されません。
これは短絡終端操作です。

引用元： Stream (Java SE 10 & JDK 10 ) 太字は引用者によるもの。

１つ目のコード同様、iterate()メソッドは無限にストリームを生成するため

評価が定まった時点で処理が打ち切られるので、問題無いのです。

import java.util.stream.Stream;

class Main {
    public static void main(String[] args) {
        Stream<String> stream = Stream.iterate("x", s -> s + s);
        stream
            .map(s -> s.length() > 3)
            .peek(System.out::println)
            .noneMatch(tf -> tf)          // 全ての要素がfalseであるか？
        ;
    }
}

実行結果 Wandbox

false
false
true

元のコードはなにが問題か？

Predicate<? super String> p = s -> s.startsWith("g");
Stream<String> st1 = Stream.generate(() -> "orange");
Stream<String> st2 = Stream.generate(() -> "gold"));
System.out.print(st1.anyMatch(p) + " ");
System.out.println(st2.allMatch(p));

理由は、generate()メソッドはlimit()などで終了しないと無限にストリームが生成されるためとのことです。

st1
0. よし、gで始まる文字列が一つでもあるかな？
0. orangeはgから始まらないな。次。
0. orangeはgから始まらないな。次。
0. orangeはgから始まらないな。次。
0. orangeはgから始まらないな。次。
0. 以下、延々と続きます。

st2
0. よし、gで始まらない文字列は一つでもあるかな？
0. goldはgから始まるな。次。
0. goldはgから始まるな。次。
0. goldはgから始まるな。次。
0. goldはgから始まるな。次。
0. 以下、延々と続きます。

Answer 3

ハングするかどうかと、例外が発生するかどうかでは、論点がまるっきり違うことに気付いてください。

Comments

[退会済みユーザー]

指摘及び回答いただきありがとうございます。
おっしゃる通りです。
ハングすることと実行時エラーすることとはまるっきり違うという点に気づかなかった自分がとても恥ずかしいです。

ただとてもスッキリしました。
ありがとうございます。