java - 为什么在同一流上调用两个终端操作后不会抛出 IllegalStateException？

Question

我了解到 collect() 和 forEach() 都是流终端操作，在同一个流上调用它们会抛出 非法状态异常。但是，以下代码可以成功编译并按升序打印每个字符串的长度。不会引发任何异常。怎么会这样？

List<String> list = Arrays.asList("ant", "bird", "chimpanzee", "dolphin");
list.stream().collect(Collectors.groupingBy(String::length))
        .forEach((a, b) -> System.out.println(a));

Answer 1

您调用的 forEach 方法不是 Stream::forEach 方法，而是 Map::forEach方法，就像您在 collect(...) 的返回值上调用它一样，它是一个 Map。 Map::forEach 方法的一个功能是它采用 BiConsumer，而不是 Consumer。流的 forEach 永远不会采用带有两个参数的 lambda!

因此，您只调用一个终端操作，即流上的 collect 。在那之后，您再也没有对流执行任何操作(您开始使用返回的 Map )，这就是为什么没有抛出 IllegalStateExcepton 的原因。

要在同一个流上实际调用两个终端操作，您需要首先将流放入变量中:

List<String> list = Arrays.asList("ant", "bird", "chimpanzee", "dolphin");
Stream<String> stream = list.stream(); // you need this extra variable.
stream.collect(Collectors.groupingBy(String::length));
stream.forEach((a) -> System.out.println(a)); // this will throw an exception, as expected