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

Simplify the boolean expression (#26855)

Browse source
This commit is contained in:
Shutao Tang 2019-05-06 16:09:06 +08:00 • committed by Johan Andrén
parent 3b538dc84c
commit c70370b4d6
3 changed files with 6 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-actor/src/main/scala/akka/actor/ActorRefProvider.scala
View file

@ -407,7 +407,7 @@ private[akka] class LocalActorRefProvider private[akka] (
def provider: ActorRefProvider = LocalActorRefProvider.this
def isWalking = causeOfTermination.future.isCompleted == false
def isWalking = !causeOfTermination.future.isCompleted
override def stop(): Unit = {
causeOfTermination.trySuccess(

2
akka-actor/src/main/scala/akka/dispatch/BalancingDispatcher.scala
View file

@ -103,7 +103,7 @@ private[akka] class BalancingDispatcher(
if (messageQueue.hasMessages
&& i.hasNext
&& (executorService.executor match {
case lm: LoadMetrics => lm.atFullThrottle == false
case lm: LoadMetrics => !lm.atFullThrottle
case _ => true
})
&& !registerForExecution(i.next.mailbox, false, false))

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

@ -258,7 +258,7 @@ private[akka] abstract class Mailbox(val messageQueue: MessageQueue)
@tailrec private final def processMailbox(
left: Int = java.lang.Math.max(dispatcher.throughput, 1),
deadlineNs: Long =
if (dispatcher.isThroughputDeadlineTimeDefined == true)
if (dispatcher.isThroughputDeadlineTimeDefined)
System.nanoTime + dispatcher.throughputDeadlineTime.toNanos
else 0L): Unit =
if (shouldProcessMessage) {
@ -269,7 +269,7 @@ private[akka] abstract class Mailbox(val messageQueue: MessageQueue)
if (Thread.interrupted())
throw new InterruptedException("Interrupted while processing actor messages")
processAllSystemMessages()
if ((left > 1) && ((dispatcher.isThroughputDeadlineTimeDefined == false) || (System.nanoTime - deadlineNs) < 0))
if ((left > 1) && (!dispatcher.isThroughputDeadlineTimeDefined || (System.nanoTime - deadlineNs) < 0))
processMailbox(left - 1, deadlineNs)
}
}
@ -284,7 +284,7 @@ private[akka] abstract class Mailbox(val messageQueue: MessageQueue)
final def processAllSystemMessages(): Unit = {
var interruption: Throwable = null
var messageList = systemDrain(SystemMessageList.LNil)
while ((messageList.nonEmpty) && !isClosed) {
while (messageList.nonEmpty && !isClosed) {
val msg = messageList.head
messageList = messageList.tail
msg.unlink()
@ -294,7 +294,7 @@ private[akka] abstract class Mailbox(val messageQueue: MessageQueue)
if (Thread.interrupted())
interruption = new InterruptedException("Interrupted while processing system messages")
// don’t ever execute normal message when system message present!
if ((messageList.isEmpty) && !isClosed) messageList = systemDrain(SystemMessageList.LNil)
if (messageList.isEmpty && !isClosed) messageList = systemDrain(SystemMessageList.LNil)
}
/*
* if we closed the mailbox, we must dump the remaining system messages