假设我的流量为1,000,全部为1.
scala> val million = Stream.fill(100000000)(1) million: scala.collection.immutable.Stream[Int] = Stream(1,?) scala> million filter (x => x % 2 == 0) Exception in thread "main" java.lang.OutOfMemoryError: GC overhead limit exceeded
我得到一个Out of Memory异常.
然后,我尝试使用List进行相同的过滤器调用.
scala> val y = List.fill(1000000)(1) y: List[Int] = List(1,1,1 ... scala> y.filter(x => x % 2 == 0) res2: List[Int] = List()
但它成功了.
为什么Stream#filter在这里耗尽内存,但List#过滤器完成得很好？
最后,对于大流,会过滤导致整个流的非惰性评估吗？
解决方法
列表的开销 – 单个对象(实例：:)每个元素有2个字段(2个指针).
Stream的开销 – Cons的实例(具有3个指针)加上Function的实例(tl：=> Stream [A]),用于对每个元素的Stream#tail进行延迟评估.
因此,您将在Stream上花费大约2倍的内存.
您已将Stream定义为val.或者你可以将百万作为def定义 – 在这种情况下,过滤器GC将删除所有创建的元素,然后你将获得你的记忆.
请注意,只有Stream中的尾部是惰性的,head是严格的,因此filter会严格评估,直到它获得满足给定谓词的第一个元素,并且因为Stream过滤器中没有这样的元素迭代所有百万个流并将所有元素放入记忆.
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。