blob: eb294681602d6b48e515eb81c68f0d22159b4e5f (
plain) (
tree)
|
|
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]) {
val n = try { args(0).toInt }
catch {
case _ =>
println("Usage: examples.actors.message <n>")
Predef.exit
}
val nActors = 500
val finalSum = n * nActors
//Scheduler.impl = new SingleThreadedScheduler
Debug.level = 3
Scheduler.impl = {
val s = new ResizableThreadPoolScheduler(false)
s.start()
s
}
def beh(next: Actor, sum: Int) {
react {
case value: Int =>
val j = value + 1; val nsum = sum + j
if (next == null && nsum >= n * j)
println(nsum)
else {
if (next != null) next ! j
if (nsum < n * j) beh(next, nsum)
}
}
}
def actorChain(i: Int, a: Actor): Actor =
if (i > 0) actorChain(i-1, actor(beh(a, 0))) else a
val firstActor = actorChain(nActors, null)
var i = n; while (i > 0) { firstActor ! 0; i -= 1 }
//Scheduler.shutdown()
}
}
|