diff options
author | Philipp Haller <hallerp@gmail.com> | 2009-10-26 21:01:12 +0000 |
---|---|---|
committer | Philipp Haller <hallerp@gmail.com> | 2009-10-26 21:01:12 +0000 |
commit | f3068614fb38fc08be54ac1179a1cfec52b8b13b (patch) | |
tree | 76ee219f209559d900b17682e29c9aaf9b3d73ab /docs/examples/actors/message.scala | |
parent | 63b1fd9be6c8c9e28092d775037c695af4b264e3 (diff) | |
download | scala-f3068614fb38fc08be54ac1179a1cfec52b8b13b.tar.gz scala-f3068614fb38fc08be54ac1179a1cfec52b8b13b.tar.bz2 scala-f3068614fb38fc08be54ac1179a1cfec52b8b13b.zip |
Second half of fix and tests for #1518.
Diffstat (limited to 'docs/examples/actors/message.scala')
-rw-r--r-- | docs/examples/actors/message.scala | 12 |
1 files changed, 10 insertions, 2 deletions
diff --git a/docs/examples/actors/message.scala b/docs/examples/actors/message.scala index d385543470..eb29468160 100644 --- a/docs/examples/actors/message.scala +++ b/docs/examples/actors/message.scala @@ -3,6 +3,8 @@ package examples.actors import scala.actors.{Actor, Scheduler} import scala.actors.Actor._ import scala.actors.scheduler.SingleThreadedScheduler +import scala.actors.{Debug, Scheduler} +import scala.actors.scheduler.ResizableThreadPoolScheduler object message { def main(args: Array[String]) { @@ -14,7 +16,13 @@ object message { } val nActors = 500 val finalSum = n * nActors - Scheduler.impl = new SingleThreadedScheduler + //Scheduler.impl = new SingleThreadedScheduler + Debug.level = 3 + Scheduler.impl = { + val s = new ResizableThreadPoolScheduler(false) + s.start() + s + } def beh(next: Actor, sum: Int) { react { @@ -35,6 +43,6 @@ object message { val firstActor = actorChain(nActors, null) var i = n; while (i > 0) { firstActor ! 0; i -= 1 } - Scheduler.shutdown() + //Scheduler.shutdown() } } |