From 57261cf375a8442a267b918ed582af526f8491fa Mon Sep 17 00:00:00 2001 From: Philipp Haller Date: Mon, 8 Mar 2010 15:01:53 +0000 Subject: Reactor now has type parameter. --- test/files/jvm/actor-getstate.scala | 73 +++++++++++++++++++++++++++++++++++++ 1 file changed, 73 insertions(+) create mode 100644 test/files/jvm/actor-getstate.scala (limited to 'test/files/jvm/actor-getstate.scala') diff --git a/test/files/jvm/actor-getstate.scala b/test/files/jvm/actor-getstate.scala new file mode 100644 index 0000000000..9de3247653 --- /dev/null +++ b/test/files/jvm/actor-getstate.scala @@ -0,0 +1,73 @@ +import scala.actors.{Reactor, Actor, TIMEOUT} + +object Test { + + def assert(cond: => Boolean) { + if (!cond) + println("FAIL") + } + + def main(args: Array[String]) { + val a = new Reactor[Any] { + def act() { + assert(getState == Actor.State.Runnable) + react { + case 'go => + println("OK") + } + } + } + assert(a.getState == Actor.State.New) + + a.start() + Thread.sleep(100) + assert(a.getState == Actor.State.Suspended) + + a ! 'go + Thread.sleep(100) + assert(a.getState == Actor.State.Terminated) + + val b = new Actor { + def act() { + assert(getState == Actor.State.Runnable) + react { + case 'go => + reactWithin(100000) { + case TIMEOUT => + case 'go => + receive { + case 'go => + } + receiveWithin(100000) { + case TIMEOUT => + case 'go => + println("OK") + } + } + } + } + } + assert(b.getState == Actor.State.New) + + b.start() + Thread.sleep(100) + assert(b.getState == Actor.State.Suspended) + + b ! 'go + Thread.sleep(100) + assert(b.getState == Actor.State.TimedSuspended) + + b ! 'go + Thread.sleep(100) + assert(b.getState == Actor.State.Blocked) + + b ! 'go + Thread.sleep(100) + assert(b.getState == Actor.State.TimedBlocked) + + b ! 'go + Thread.sleep(100) + assert(b.getState == Actor.State.Terminated) + } + +} -- cgit v1.2.3