From ac311a32c287f18f4fa4439d512ccda7b6be2bf0 Mon Sep 17 00:00:00 2001
From: Viktor Klang <viktor.klang@gmail.com>
Date: Sat, 9 Jul 2011 19:17:49 +0200
Subject: [PATCH] Fixing a visibility problem with Scheduler thread id

---
 akka-actor/src/main/scala/akka/actor/Scheduler.scala | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/akka-actor/src/main/scala/akka/actor/Scheduler.scala b/akka-actor/src/main/scala/akka/actor/Scheduler.scala
index 37eb363219..c6c978275f 100644
--- a/akka-actor/src/main/scala/akka/actor/Scheduler.scala
+++ b/akka-actor/src/main/scala/akka/actor/Scheduler.scala
@@ -21,6 +21,7 @@ import java.util.concurrent._
 
 import akka.event.EventHandler
 import akka.AkkaException
+import atomic.AtomicLong
 
 object Scheduler {
   import Actor._
@@ -133,12 +134,12 @@ object Scheduler {
 }
 
 private object SchedulerThreadFactory extends ThreadFactory {
-  private var count = 0
+  private val count = new AtomicLong(0)
   val threadFactory = Executors.defaultThreadFactory()
 
   def newThread(r: Runnable): Thread = {
     val thread = threadFactory.newThread(r)
-    thread.setName("akka:scheduler-" + count)
+    thread.setName("akka:scheduler-" + count.incrementAndGet())
     thread.setDaemon(true)
     thread
   }