takeWhile,dropWhile laziness java9

发布时间：2020-12-15 02:48:00 所属栏目：Java 来源：网络整理

导读：在 scala中,这些方法工作正常,但在 java9中,dropWhile的工作方式与我想的不同. 以下是takeWhile的示例 Stream.of("a","b","c","de","f","g","h") .peek(System.out::println) .takeWhile(s - s.length() = 1) .collect(Collectors.toList()); 输出很好： a,b

在 scala中,这些方法工作正常,但在 java9中,dropWhile的工作方式与我想的不同.

以下是takeWhile的示例

Stream.of("a","b","c","de","f","g","h")
                .peek(System.out::println)
                .takeWhile(s -> s.length() <= 1)
                .collect(Collectors.toList());

输出很好：
a,b,c,de,[a,c]
它不会在“de”之后处理元素,因此它按预期工作

但是DropWhile以我期望的不同方式工作：

Stream.of("a","h")
                .peek(s -> System.out.print(s + ","))
                .dropWhile(s -> s.length() <= 1)
                .collect(Collectors.toList());

输出是：
a,f,g,h,[de,h]

因此它不会在“de”元素之后停止,它正在处理整个集合.

为什么要处理整个系列？我知道,需要采取所有元素并将其收集到列表中,但不应该在“de”元素之后停止处理吗？

解决方法

看来,对于窥视的工作方式存在根本性的误解.它与下一个后续链接操作(如dropWhile)无关,而是与其后面的整个Stream管道相关联.它并没有区分“处理元素”和“占用所有元素”.

所以简单的代码

Stream.of("a","h")
      .peek(System.out::println)
      .collect(Collectors.toList());

“获取所有元素”,但在将它们从Stream源传递到收集器时打印它们.

在您的示例中,无论是将元素传递给dropWhile的谓词还是直接传递给收集器都没有区别,在任何一种情况下,它都将通过放在两者之前的peek操作进行报告.

如果你使用

Stream.of("a","h")
      .dropWhile(s -> {
          System.out.println("dropWhile: "+s);
          return s.length() <= 1;
      })
      .peek(s -> System.out.println("collecting "+s))
      .collect(Collectors.toList());

相反,它会打印出来

dropWhile: a
dropWhile: b
dropWhile: c
dropWhile: de
collecting de
collecting f
collecting g
collecting h

显示dropWhile的谓词的评估如何在第一个未接受的元素之后停止,而向收集器的传输以该元素开始.

这与takeWhile不同,其中谓词评估和收集器都停止使用元素,因此没有消费者,整个Stream管道可以停止迭代源.

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!