flux Scala itérer et la gestion de la mémoire

Question

J'ai ce code:

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

L'idée est de fournir un état initial initCompState, une fonction qui génère un nouvel état de la précédente, exécutez pour nIterations et obtenir la résultat final.

Je ne suis pas interessé par les états intermédiaires, et je voudrais qu'ils soient collectés dès qu'ils ne sont pas nécessaires. De ce que j'ai lu en ligne, Stream conserve des valeurs lorsqu'elles sont définies récursivement, ce qui n'est pas le cas ici.

Mon implémentation est-elle correcte et les états intermédiaires entre les gares initCompState et res sont-ils collectés dès que l'état suivant dans le flux a été calculé?

Answer 1

Stream est IterableAgain, ce qui signifie qu'il conservera tous les éléments que vous parcourez au cas où vous voudriez les voir à nouveau.

Iterator est plus approprié dans votre cas, vous pouvez passer en revue une fois, donc, il rejette chaque élément dès que vous le regardez. Il n'a pas last, donc, vous auriez à mettre en œuvre vous-même avec quelque chose comme

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

Vous pouvez également mettre en œuvre simplement vos itérations récursive:

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

val result = iterate(nIteration)