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

Spellchecking and elided a try-block

Browse source
This commit is contained in:
Viktor Klang 2011-02-14 02:51:26 +01:00
parent 05c12742e3
commit 4c0b9110c9
1 changed files with 5 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -163,7 +163,9 @@ trait ExecutableMailbox extends Runnable { self: MessageQueue =>
final def run = { final def run = {
try { try {
try { processMailbox() } catch { case ie: InterruptedException => true } processMailbox()
} catch {
case ie: InterruptedException =>
} finally { } finally {
dispatcherLock.unlock() dispatcherLock.unlock()
} }
@ -193,10 +195,10 @@ trait ExecutableMailbox extends Runnable { self: MessageQueue =>
if (self.suspended.locked) { if (self.suspended.locked) {
null //If we are suspended, abort null //If we are suspended, abort
} }
else { //If we aren't suspended, we need to make sure we're not overstepping our boundraries else { //If we aren't suspended, we need to make sure we're not overstepping our boundaries
processedMessages += 1 processedMessages += 1
if ((processedMessages >= dispatcher.throughput) || (isDeadlineEnabled && System.nanoTime >= deadlineNs)) // If we're throttled, break out if ((processedMessages >= dispatcher.throughput) || (isDeadlineEnabled && System.nanoTime >= deadlineNs)) // If we're throttled, break out
null //We reached our boundraries, abort null //We reached our boundaries, abort
else else
self.dequeue //Dequeue the next message self.dequeue //Dequeue the next message
} }