Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Memory leaks when calling Future.flatMap #7336

Closed
scabug opened this issue Apr 5, 2013 · 2 comments
Closed

Memory leaks when calling Future.flatMap #7336

scabug opened this issue Apr 5, 2013 · 2 comments
Assignees
Labels
Milestone

Comments

@scabug
Copy link

scabug commented Apr 5, 2013

Following up this thread: https://groups.google.com/forum/?fromgroups=#!topic/play-framework-dev/58VZD-YXdJw

Using a lot of flatMap calls leaks. Here is a snippet of code that shows the problem:

import scala.concurrent._
import scala.concurrent.duration._
import ExecutionContext.Implicits.global
import scala.util._

object FutureLeak extends App {
val step = 100000
val upper = 1000000

// code that leaks
def loop(future: Future[Int]): Future[Int] = {
future.flatMap { i =>
if (i % step == 0) println(i)
if (i < upper)
loop(Future(i + 1))
else Future(i)
}
}

// code that does not leak
def loop2(future: Future[Int]): Future[Int] = {
val promise = Promise[Int]

def inloop(future: Future[Int]): Unit = {
  future.onComplete {
    case Success(i) if i < upper =>
      if (i % step == 0) println(i)
      inloop(Future(i + 1))
    case Success(i) =>
      println("done with " + i)
      promise.success(i)
  }
}

inloop(future)
promise.future

}

Await.result(loop(Future(0)), 100 seconds) // leads to java.lang.OutOfMemoryError: Java heap space with -Xms32m -Xmx32m

Await.result(loop2(Future(0)), 100 seconds) // runs fine with -Xms32m -Xmx32m
}

It should not leak since the produced futures do not depend on each other.

@scabug
Copy link
Author

scabug commented Apr 5, 2013

Imported From: https://issues.scala-lang.org/browse/SI-7336?orig=1
Reporter: Stephane Godbillon (sgodbillon)
Affected Versions: 2.10.0, 2.10.1
See #7493

@scabug
Copy link
Author

scabug commented Jul 12, 2013

@adriaanm said:
scala/scala#2674

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Projects
None yet
Development

No branches or pull requests

2 participants