scala – 为什么Stream.filter内存不足？

Stream.from(1).filter(_ < 0).head
Stream.from(1).find(_ < 0)

应该循环,直到它们返回Int.MinValue.这正是具有过滤器的版本所做的,但是在查找时会生成OutOfMemoryError.看看他们的实现,我无法弄清楚两个版本都不会产生OutOfMemoryError.

以下是Stream.filter的实现：

override def filter(p: A => Boolean): Stream[A] = {
  // optimization: drop leading prefix of elems for which f returns false
  // var rest = this dropWhile (!p(_)) - forget DRY principle - GC can't collect otherwise
  var rest = this
  while (!rest.isEmpty && !p(rest.head)) rest = rest.tail
  // private utility func to avoid `this` on stack (would be needed for the lazy arg)
  if (rest.nonEmpty) Stream.filteredTail(rest,p)
  else Stream.Empty
}

find继承自LinearSeqOptimized,具有以下定义：

override /*IterableLike*/
def find(p: A => Boolean): Option[A] = {
  var these = this
  while (!these.isEmpty) {
    if (p(these.head)) return Some(these.head)
    these = these.tail
  }
  None
}

它们都有一个while循环,它丢弃了不满足谓词的Stream元素.因为这应该保持对Stream开头的引用,所有这些创建的元素应该在内存中累积,直到我们用完空间.除非我真的误解了这里发生的事情,否则Stream.filter会在进入while循环之前以某种方式从堆栈帧中消除它.关于为什么不使用dropWhile的Stream.filter中的注释看起来像一个提示,但我不知道它指的是什么.

我的下一步是学习如何反汇编和读取JVM字节码,但我真的希望有人知道这里发生了什么.