From d569b29a8bfd04241bc93b6293243f6456cf8106 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jonas=20Bon=C3=A9r?= Date: Sun, 14 Mar 2010 18:01:49 +0100 Subject: [PATCH] dispatcher speed improvements --- .../ExecutorBasedEventDrivenDispatcher.scala | 13 +++++++------ project/build/AkkaProject.scala | 5 +++-- 2 files changed, 10 insertions(+), 8 deletions(-) diff --git a/akka-core/src/main/scala/dispatch/ExecutorBasedEventDrivenDispatcher.scala b/akka-core/src/main/scala/dispatch/ExecutorBasedEventDrivenDispatcher.scala index e115800d4b..68e537ae82 100644 --- a/akka-core/src/main/scala/dispatch/ExecutorBasedEventDrivenDispatcher.scala +++ b/akka-core/src/main/scala/dispatch/ExecutorBasedEventDrivenDispatcher.scala @@ -62,13 +62,14 @@ class ExecutorBasedEventDrivenDispatcher(_name: String) extends MessageDispatche def dispatch(invocation: MessageInvocation) = if (active) { executor.execute(new Runnable() { def run = { - invocation.receiver.synchronized { +// invocation.receiver.synchronized { var messageInvocation = invocation.receiver._mailbox.poll - while (messageInvocation != null) { - messageInvocation.invoke - messageInvocation = invocation.receiver._mailbox.poll - } - } + if (messageInvocation != null) messageInvocation.invoke +// while (messageInvocation != null) { +// messageInvocation.invoke +// messageInvocation = invocation.receiver._mailbox.poll +// } +// } } }) } else throw new IllegalStateException("Can't submit invocations to dispatcher since it's not started") diff --git a/project/build/AkkaProject.scala b/project/build/AkkaProject.scala index 2df647a5bd..d6f2a1d79d 100644 --- a/project/build/AkkaProject.scala +++ b/project/build/AkkaProject.scala @@ -127,9 +127,10 @@ class AkkaParent(info: ProjectInfo) extends DefaultProject(info) { Credentials(Path.userHome / ".akka_publish_credentials", log) override def managedStyle = ManagedStyle.Maven - val publishTo = "Scalable Solutions Maven Repository" at "http://scalablesolutions.se/akka/repository/" + val publishTo = "Scalable Solutions Maven Repository" at "~/tmp/akka" +// val publishTo = "Scalable Solutions Maven Repository" at "http://scalablesolutions.se/akka/repository/" val sourceArtifact = Artifact(artifactID, "src", "jar", Some("sources"), Nil, None) - val docsArtifact = Artifact(artifactID, "docs", "jar", Some("javadoc"), Nil, None) +// val docsArtifact = Artifact(artifactID, "docs", "jar", Some("javadoc"), Nil, None) override def packageDocsJar = defaultJarPath("-javadoc.jar") override def packageSrcJar= defaultJarPath("-sources.jar")