speedup MessageBus.hasUndeliveredEvents (inspired by IDEA-182529)

This commit is contained in:
peter
2017-11-22 22:53:26 +01:00
parent bba6edf05b
commit 0420d5cbb5
2 changed files with 6 additions and 2 deletions
@@ -139,7 +139,10 @@ public class MessageBusConnectionImpl implements MessageBusConnection {
}
boolean containsMessage(@NotNull Topic topic) {
for (Message message : myPendingMessages.get()) {
Queue<Message> pendingMessages = myPendingMessages.get();
if (pendingMessages.isEmpty()) return false;
for (Message message : pendingMessages) {
if (message.getTopic() == topic) {
return true;
}
@@ -301,7 +301,8 @@ public class MessageBusImpl implements MessageBus {
}
private boolean isDispatchingAnything() {
return getRootBus().myWaitingBuses.get() != null;
SortedMap<MessageBusImpl, Integer> waitingBuses = getRootBus().myWaitingBuses.get();
return waitingBuses != null && !waitingBuses.isEmpty();
}
private void checkNotDisposed() {