Added method for defining an actor with a (type...

Added method for defining an actor with a (typed) input channel.

1 files changed, 10 insertions, 1 deletions

diff --git a/src/actors/scala/actors/Actor.scala b/src/actors/scala/actors/Actor.scala
index 4397032b60..f6dc77d672 100644
--- a/src/actors/scala/actors/Actor.scala
+++ b/src/actors/scala/actors/Actor.scala
@@ -28,6 +28,15 @@ object Actor {
     actor
   }
 
+  def actor[a](ch: Channel[a])(body: => Unit): ActorThread = synchronized {
+    val actor = new ActorThread {
+      def act() = body
+    }
+    ch.receiver = actor
+    actor.start()
+    actor
+  }
+
   def reactor(body: => Unit): Reactor = synchronized {
     val reactor = new Reactor {
       def act() = body
@@ -272,7 +281,7 @@ class ActorProxy(t: Thread) extends ThreadedActor {
   def act(): Unit = {}
   def exit(reason: String): Unit = {
     exitReason = reason
-    Thread.currentThread().interrupt()
+    t.interrupt()
   }
 }