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

make sure lock is aquired when accessing shutdownSchedule

Browse source
This commit is contained in:
Derek Williams 2011-04-28 07:47:51 -06:00
parent 485013a353
commit c61f1a42dc
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-actor/src/main/scala/akka/dispatch/MessageHandling.scala
View file

@ -95,7 +95,7 @@ trait MessageDispatcher {
}
private val futureCleanup: () => Unit = { () =>
if (futures.decrementAndGet() == 0 && uuids.isEmpty) {
if (futures.decrementAndGet() == 0) guard withGuard { if (uuids.isEmpty) {
shutdownSchedule match {
case UNSCHEDULED =>
shutdownSchedule = SCHEDULED
@ -104,7 +104,7 @@ trait MessageDispatcher {
shutdownSchedule = RESCHEDULED
case RESCHEDULED => //Already marked for reschedule
}
}
}}
}
private[akka] def register(actorRef: ActorRef) {