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

fixed round robin work stealing algorithm

Browse source
This commit is contained in:
Jan Van Besien 2010-03-30 11:50:36 +02:00
parent 195157768d
commit 067cc73a8f
1 changed files with 6 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -105,7 +105,7 @@ class ExecutorBasedEventDrivenWorkStealingDispatcher(_name: String) extends Mess
// the dispatcher is being shut down...
doFindThief(receiver, pooledActorsCopy, lastIndexCopy) match {
case (thief: Option[Actor], index: Int) => {
lastIndex = index
lastIndex = (index + 1) % pooledActorsCopy.size
return thief
}
}
@ -121,14 +121,15 @@ class ExecutorBasedEventDrivenWorkStealingDispatcher(_name: String) extends Mess
*/
private def doFindThief(receiver: Actor, actors: Array[Actor], startIndex: Int): (Option[Actor], Int) = {
for (i <- 0 to actors.length) {
val actor = actors((i + startIndex) % actors.length)
val index = (i + startIndex) % actors.length
val actor = actors(index)
if (actor != receiver) { // skip ourselves
if (actor._mailbox.isEmpty) { // only pick actors that will most likely be able to process the messages
return (Some(actor), i)
return (Some(actor), index)
}
}
}
return (None, 0)
return (None, startIndex) // nothing found, reuse same start index next time
}
/**
@ -214,4 +215,4 @@ class ExecutorBasedEventDrivenWorkStealingDispatcher(_name: String) extends Mess
}
}
}
}
}