diff options
Diffstat (limited to 'test/files/jvm/actorgc_leak.scala')
-rw-r--r-- | test/files/jvm/actorgc_leak.scala | 63 |
1 files changed, 63 insertions, 0 deletions
diff --git a/test/files/jvm/actorgc_leak.scala b/test/files/jvm/actorgc_leak.scala new file mode 100644 index 0000000000..5e2b9d51e1 --- /dev/null +++ b/test/files/jvm/actorgc_leak.scala @@ -0,0 +1,63 @@ + +import scala.actors.Actor + +object Test { + class FatActorFactory extends Actor { + def act() { + var cnt = 0 + Actor.loopWhile(cnt < fatActors) { + //if ((cnt % 5) == 0) println(cnt) + val fa = new FatActor() + fa.start() + cnt += 1 + if (cnt == fatActors) Monitor ! 'done + } + } + } + + class FatActor extends Actor { + def act() { + fat = new Array[Int](fatness) + react { + case 'hi => exit() + } + } + private var fat: Array[Int] = _ + } + + object Monitor extends Actor { + private var cnt = 0 + def act() { + Actor.loop { + react { + case 'done => { + cnt += 1 + if (cnt == factories) System.exit(0) // once GC pressure stops FatActors stop being collected, and as + } // a result ActorGC never finds out that they are defunct + } + } + } + } + + val factories = 4 // the number of factories to start + val fatActors = 50 // the number of FatActors for each factory to produce + val fatness = 1024*1024*10 + + def main(args: Array[String]) { + scala.actors.Scheduler.impl.shutdown() + val sched = { + val s = new scala.actors.FJTaskScheduler2 + s.start() + s + } + scala.actors.Scheduler.impl = sched + + Monitor.start() + for(i <- 1 to factories) { + //if ((i % 50) == 0) println(i) + val fa = new FatActorFactory() + fa.start() + } + println("Done") + } +} |