raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Changed Supervisors actor map to hold a list of actors per class entry

Browse source
This commit is contained in:
Jonas Bonér 2010-03-18 08:37:44 +01:00
parent 86e656d416
commit 1f13030f90
6 changed files with 61 additions and 78 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-core/src/main/scala/stm/DataFlowVariable.scala
View file

@ -19,6 +19,12 @@ object DataFlow {
case object Start
case object Exit
import java.util.concurrent.atomic.AtomicReference
import java.util.concurrent.{ConcurrentLinkedQueue, LinkedBlockingQueue}
import se.scalablesolutions.akka.actor.Actor
import se.scalablesolutions.akka.dispatch.CompletableFuture
def thread(body: => Unit) = {
val thread = new IsolatedEventBasedThread(body).start
thread send Start