summaryrefslogtreecommitdiff
path: root/docs
diff options
context:
space:
mode:
authorPhilipp Haller <hallerp@gmail.com>2009-10-26 21:01:12 +0000
committerPhilipp Haller <hallerp@gmail.com>2009-10-26 21:01:12 +0000
commitf3068614fb38fc08be54ac1179a1cfec52b8b13b (patch)
tree76ee219f209559d900b17682e29c9aaf9b3d73ab /docs
parent63b1fd9be6c8c9e28092d775037c695af4b264e3 (diff)
downloadscala-f3068614fb38fc08be54ac1179a1cfec52b8b13b.tar.gz
scala-f3068614fb38fc08be54ac1179a1cfec52b8b13b.tar.bz2
scala-f3068614fb38fc08be54ac1179a1cfec52b8b13b.zip
Second half of fix and tests for #1518.
Diffstat (limited to 'docs')
-rw-r--r--docs/examples/actors/fringe.scala9
-rw-r--r--docs/examples/actors/message.scala12
2 files changed, 19 insertions, 2 deletions
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()
}
}