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

Sprinkling some final magic sauce

Browse source
This commit is contained in:
Viktor Klang 2011-12-01 23:43:56 +01:00
parent ef27f865d4
commit bf7befc690
1 changed files with 7 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

14
akka-actor/src/main/scala/akka/dispatch/ThreadPoolBuilder.scala
View file

@ -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() }
}
}