Fixed bug in shutdown management of global event-based dispatcher

This commit is contained in:
Jonas Bonér 2010-01-02 08:40:09 +01:00
parent cc0517d559
commit cb019e9e4d
6 changed files with 22 additions and 6 deletions

View file

@ -39,9 +39,13 @@ class ThreadBasedDispatcher private[akka] (val name: String, val messageHandler:
selectorThread.start
}
def isShutdown = !active
def shutdown = if (active) {
log.debug("Shutting down ExecutorBasedEventDrivenDispatcher [%s]", name)
active = false
selectorThread.interrupt
references.clear
}
}