Scala Stream与Java Stream Laziness的区别

Question

我是懒惰评估概念的新手.当我在Scala中执行这行代码时;

"12334".grouped(1).toStream.filter{n => println("n:" +n ); n=="3";}

打印出来:

n:1
n:2
n:3

但是当我在Java中运行类似的东西时,例如:

List<String> myList = new ArrayList<>(Arrays.asList("12334".split("")));

Stream<String> myList2 = myList.stream().filter(a -> {System.out.println("a:" +a);return "3".equals(a);});

它无声地终止,无需向控制台行写任何内容.Java的行为对我来说似乎更合理,因为Streams被懒惰地评估,我没有收集或尝试打印结果.但是在Scala中,即使我没有消耗流,它也会输出一些信息.所以我的问题是导致这种差异的原因是什么？

Answer 1

这是因为事实filter并非完全是懒惰的.它有这段代码:

while (!rest.isEmpty && !p(rest.head)) rest = rest.tail

这导致了物化和实际过滤Stream.

如果你想要完全懒惰,请选择withFilter:

"12334".grouped(1).toStream.withFilter { n => println("n:" +n ); n=="3"; }

有关详细信息,请参阅withFilter而不是filter.