takeWhile,dropWhile laziness java9

前端之家收集整理的这篇文章主要介绍了takeWhile,dropWhile laziness java9前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。
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管道可以停止迭代源.

猜你在找的Java相关文章