From bf7befc6905930c4f1eabf2f868730b64c82ee73 Mon Sep 17 00:00:00 2001 From: Viktor Klang Date: Thu, 1 Dec 2011 23:43:56 +0100 Subject: [PATCH] Sprinkling some final magic sauce --- .../scala/akka/dispatch/ThreadPoolBuilder.scala | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/akka-actor/src/main/scala/akka/dispatch/ThreadPoolBuilder.scala b/akka-actor/src/main/scala/akka/dispatch/ThreadPoolBuilder.scala index f92be79b2d..c45cc74593 100644 --- a/akka-actor/src/main/scala/akka/dispatch/ThreadPoolBuilder.scala +++ b/akka-actor/src/main/scala/akka/dispatch/ThreadPoolBuilder.scala @@ -194,7 +194,7 @@ case class ForkJoinPoolConfig(targetParallelism: Int = Runtime.getRuntime.availa setAsyncMode(true) setMaintainsParallelism(true) - override def execute(r: Runnable) { + override final def execute(r: Runnable) { r match { case fjmbox: FJMailbox ⇒ //fjmbox.fjTask.reinitialize() @@ -224,12 +224,12 @@ case class ForkJoinPoolConfig(targetParallelism: Int = Runtime.getRuntime.availa } trait FJMailbox { self: Mailbox ⇒ - val fjTask = new ForkJoinTask[Unit] with Runnable { - var result: Unit = () - def getRawResult() = result - def setRawResult(v: Unit) { result = v } - def exec() = { self.run(); true } - def run() { invoke() } + final val fjTask = new ForkJoinTask[Unit] with Runnable { + private[this] var result: Unit = () + final def getRawResult() = result + final def setRawResult(v: Unit) { result = v } + final def exec() = { self.run(); true } + final def run() { invoke() } } }