From f3068614fb38fc08be54ac1179a1cfec52b8b13b Mon Sep 17 00:00:00 2001
From: Philipp Haller <hallerp@gmail.com>
Date: Mon, 26 Oct 2009 21:01:12 +0000
Subject: Second half of fix and tests for #1518.

---
 docs/examples/actors/fringe.scala  |  9 +++++++++
 docs/examples/actors/message.scala | 12 ++++++++++--
 2 files changed, 19 insertions(+), 2 deletions(-)

(limited to 'docs')

diff --git a/docs/examples/actors/fringe.scala b/docs/examples/actors/fringe.scala
index 2026628cb3..2afdc41b4f 100644
--- a/docs/examples/actors/fringe.scala
+++ b/docs/examples/actors/fringe.scala
@@ -2,6 +2,8 @@ package examples.actors
 
 import scala.actors.Actor._
 import scala.actors.{Channel, OutputChannel}
+import scala.actors.{Debug, Scheduler}
+import scala.actors.scheduler.ResizableThreadPoolScheduler
 
 /**
  @author Philipp Haller
@@ -18,6 +20,13 @@ object fringe extends Application {
   case class Equal(atom1: Option[Leaf], atom2: Option[Leaf])
   case class Extract(tree: Tree)
 
+  Debug.level = 3
+  Scheduler.impl = {
+    val s = new ResizableThreadPoolScheduler(false)
+    s.start()
+    s
+  }
+
   val comparator = actor {
     val extractor1 = actor(extractorBehavior())
     val extractor2 = actor(extractorBehavior())
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()
   }
 }
-- 
cgit v1.2.3