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

Adding final declarations

Browse source
This commit is contained in:
Viktor Klang 2010-09-12 15:36:32 +02:00
commit 4ab6d33925
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-actor/src/main/scala/dispatch/ExecutorBasedEventDrivenDispatcher.scala
View file

@ -84,7 +84,7 @@ class ExecutorBasedEventDrivenDispatcher(
* This is the behavior of an ExecutorBasedEventDrivenDispatchers mailbox
*/
trait ExecutableMailbox extends Runnable { self: MessageQueue =>
def run = {
final def run = {
var lockAcquiredOnce = false
var finishedBeforeMailboxEmpty = false
// this do-while loop is required to prevent missing new messages between the end of the inner while
@ -103,7 +103,7 @@ class ExecutorBasedEventDrivenDispatcher(
registerForExecution(self)
throw e
}
dispatcherLock.unlock()
if (finishedBeforeMailboxEmpty)
registerForExecution(self)
@ -116,7 +116,7 @@ class ExecutorBasedEventDrivenDispatcher(
*
* @return true if the processing finished before the mailbox was empty, due to the throughput constraint
*/
def processMailbox(): Boolean = {
final def processMailbox(): Boolean = {
val throttle = throughput > 0
var processedMessages = 0
var nextMessage = self.dequeue