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

use forward in stead of send when stealing work from another actor

Browse source
This commit is contained in:
Jan Van Besien 2010-03-30 13:11:03 +02:00
parent 067cc73a8f
commit 62cdb9fc23
1 changed files with 1 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-core/src/main/scala/dispatch/ExecutorBasedEventDrivenWorkStealingDispatcher.scala
View file

@ -168,9 +168,7 @@ class ExecutorBasedEventDrivenWorkStealingDispatcher(_name: String) extends Mess
private def donateMessage(receiver: Actor, thief: Actor): Option[MessageInvocation] = {
val donated = receiver._mailbox.pollLast
if (donated != null) {
//TODO: forward seems to fail from time to time ?!
//thief.forward(donated.message)(Some(donated.receiver))
thief.send(donated.message)
thief.forward(donated.message)(Some(donated.receiver))
return Some(donated)
} else return None
}