Removing pointless synchroniation

This commit is contained in:
Viktor Klang 2010-11-11 18:22:26 +01:00
parent 8c2ed8bd03
commit 4bdc2092c8

View file

@ -310,13 +310,11 @@ class RemoteClient private[akka] (
connection.getChannel.write(request)
None
} else {
futures.synchronized {
val futureResult = if (senderFuture.isDefined) senderFuture.get
else new DefaultCompletableFuture[T](request.getActorInfo.getTimeout)
futures.put(uuidFrom(request.getUuid.getHigh, request.getUuid.getLow), futureResult)
connection.getChannel.write(request)
Some(futureResult)
}
}
} else {
val exception = new RemoteClientException(