我是懒惰评估概念的新手.当我在Scala中执行这行代码时;
"12334".grouped(1).toStream.filter{n => println("n:" +n ); n=="3";}
打印出来:
n:1 n:2 n:3
但是当我在Java中运行类似的东西时,例如:
ListmyList = new ArrayList<>(Arrays.asList("12334".split(""))); Stream myList2 = myList.stream().filter(a -> {System.out.println("a:" +a);return "3".equals(a);});
它无声地终止,无需向控制台行写任何内容.Java的行为对我来说似乎更合理,因为Streams被懒惰地评估,我没有收集或尝试打印结果.但是在Scala中,即使我没有消耗流,它也会输出一些信息.所以我的问题是导致这种差异的原因是什么?
这是因为事实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.