diff --git a/akka-actor/src/main/scala/akka/actor/ActorRegistry.scala b/akka-actor/src/main/scala/akka/actor/ActorRegistry.scala index 9fb24a970e..702fb93a08 100644 --- a/akka-actor/src/main/scala/akka/actor/ActorRegistry.scala +++ b/akka-actor/src/main/scala/akka/actor/ActorRegistry.scala @@ -35,10 +35,7 @@ private[actor] final class ActorRegistry private[actor] () extends ListenerManag /** * Finds the actor that has a specific address. */ - def actorFor(address: String): Option[ActorRef] = { - if (actorsByAddress.containsKey(address)) Some(actorsByAddress.get(address)) - else None - } + def actorFor(address: String): Option[ActorRef] = Option(actorsByAddress.get(address)) /** * Finds the typed actors that have a specific address. diff --git a/akka-actor/src/main/scala/akka/dispatch/BalancingDispatcher.scala b/akka-actor/src/main/scala/akka/dispatch/BalancingDispatcher.scala index 04afac83e6..e7b2f98c9b 100644 --- a/akka-actor/src/main/scala/akka/dispatch/BalancingDispatcher.scala +++ b/akka-actor/src/main/scala/akka/dispatch/BalancingDispatcher.scala @@ -66,12 +66,12 @@ class BalancingDispatcher( actorRef, aType)) } - synchronized { members :+= actorRef } //Update members + members :+= actorRef //Update members, doesn't need synchronized, is guarded in attach super.register(actorRef) } protected[akka] override def unregister(actorRef: LocalActorRef) = { - synchronized { members = members.filterNot(actorRef eq) } //Update members + members = members.filterNot(actorRef eq) //Update members, doesn't need synchronized, is guarded in detach super.unregister(actorRef) }