代码之家 › 专栏 › 技术社区 › vkubicki

Scala流迭代和内存管理

scala-streams scala-collections garbage-collection scala

vkubicki · 技术社区 · 7 年前

val res = Stream // launch the real computation, which alternates E and M steps, updating the computation state
  .iterate(initCompState)(Base.emIteration)
  .take(nIteration)
  .last

其目的是提供初始状态 initCompState ,一个从上一个状态生成新状态的函数,运行此函数 nIterations

我不是中间州的人,我希望他们在不需要的时候尽快被垃圾收集。从我在网上看到的情况来看, Stream

我的实现是否正确,以及和 res

1 回复 | 直到 7 年前

Dima 7 年前

Stream 是 IterableAgain ,这意味着它将保留您迭代的所有元素,以防您想再次看到它们。

Iterator last 不过,所以,你必须自己实现它,比如

 iterator.foldLeft(Option.empty[Int])((_, n) => Some(n))

或者,只需递归地实现迭代:

 @tailrec
 def iterate(iters: Int, state: State = initCompState): State = if(iters == 0)
   state 
 else 
   iterate(iters - 1, Base.emIteration(state))

 val result = iterate(nIteration)

推荐文章

Imran · 是否应在Seq的已处理元素上进行GC?

6 年前

addmeaning · 如何用第二个序列的元素填充第一个序列

6 年前

ps0604 · 在Scala中附加到Seq不会编译

7 年前

Pratap D · scala:创建目录和文件

7 年前

spyk · Scala Seq-仅接受相同子类型的元素

7 年前

Sai · Spark scala中基于json对象参数的调用方法?

7 年前

Frank · 如何从地图中获取不同类型的元素

7 年前

Sai · 两个RDD的笛卡尔乘积和笛卡尔分解之和导致Spark(scala)?

7 年前

Ashwin Praveen · 从无循环的映射类型和数组Scala中查找公共字符串

7 年前

dks551 · 如何在scala中将嵌套地图制作为键和值的点分隔字符串

7 年前