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

#1894 - Switching to jsr166y.ThreadLocalRandom

Browse source
This commit is contained in:
Viktor Klang 2012-03-14 13:05:44 +01:00
parent c752f86ae3
commit a63e9f604b
1 changed files with 1 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-actor/src/main/scala/akka/routing/Routing.scala
View file

@ -747,10 +747,6 @@ trait SmallestMailboxLike { this: RouterConfig ⇒
def routees: Iterable[String]
private val random = new ThreadLocal[SecureRandom] {
override def initialValue = SecureRandom.getInstance("SHA1PRNG")
}
/**
* Returns true if the actor is currently processing a message.
* It will always return false for remote actors.
@ -819,7 +815,7 @@ trait SmallestMailboxLike { this: RouterConfig ⇒
deep: Boolean = false): ActorRef =
if (at >= targets.size) {
if (deep) {
if (proposedTarget.isTerminated) targets(random.get.nextInt(targets.size)) else proposedTarget
if (proposedTarget.isTerminated) targets(ThreadLocalRandom.current.nextInt(targets.size)) else proposedTarget
} else getNext(targets, proposedTarget, currentScore, 0, deep = true)
} else {
val target = targets(at)