Scalaのストリーム反復処理し、メモリ管理

Question

私はこのコードを持っている：

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は再帰的に定義されたときに値を保持しますが、ここではそうではありません。

私の実装は正しいですか？initCompStateとresストリームの次の状態が計算されるとすぐにガベージコレクションの間の中間状態ですか？

Answer 1

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)