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

merged with upstream

Browse source
This commit is contained in:
Jonas Bonér 2010-05-02 10:46:49 +02:00
commit 5e3ee65a62
1 changed files with 4 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -8,6 +8,7 @@ import java.util.concurrent.atomic.AtomicReference
import java.util.concurrent.{ConcurrentLinkedQueue, LinkedBlockingQueue} import java.util.concurrent.{ConcurrentLinkedQueue, LinkedBlockingQueue}
import se.scalablesolutions.akka.actor.{Actor, ActorID} import se.scalablesolutions.akka.actor.{Actor, ActorID}
import se.scalablesolutions.akka.actor.Actor._
import se.scalablesolutions.akka.dispatch.CompletableFuture import se.scalablesolutions.akka.dispatch.CompletableFuture
/** /**
@ -26,7 +27,7 @@ import se.scalablesolutions.akka.actor.Actor
import se.scalablesolutions.akka.dispatch.CompletableFuture import se.scalablesolutions.akka.dispatch.CompletableFuture
def thread(body: => Unit) = { def thread(body: => Unit) = {
val thread = new ActorID(() => new IsolatedEventBasedThread(body)).start val thread = newActor(() => new IsolatedEventBasedThread(body)).start
thread ! Start thread ! Start
thread thread
} }
@ -97,7 +98,7 @@ import se.scalablesolutions.akka.dispatch.CompletableFuture
} }
} }
private[this] val in = new ActorID(() => new In(this)) private[this] val in = newActor(() => new In(this))
def <<(ref: DataFlowVariable[T]) = in ! Set(ref()) def <<(ref: DataFlowVariable[T]) = in ! Set(ref())
@ -107,7 +108,7 @@ import se.scalablesolutions.akka.dispatch.CompletableFuture
val ref = value.get val ref = value.get
if (ref.isDefined) ref.get if (ref.isDefined) ref.get
else { else {
val out = new ActorID(() => new Out(this)) val out = newActor(() => new Out(this))
blockedReaders.offer(out) blockedReaders.offer(out)
val result = out !! Get val result = out !! Get
out ! Exit out ! Exit