diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2023-10-10 13:09:57 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2023-10-10 13:09:57 +0200 |
commit | 888a2e3fb78955580c4bdfccb722f631da28c997 (patch) | |
tree | 9e4a17fe7c26441ef5e67748c5a8189b4a2ead55 /messagebus | |
parent | 3f4b963ea783c6153542aadfb47139c1dbc888aa (diff) |
Use Boolean instead of Object
Diffstat (limited to 'messagebus')
-rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java | 11 |
1 files changed, 5 insertions, 6 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java b/messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java index 671e59dc7c9..f19d33c87b8 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java @@ -21,8 +21,7 @@ public class Sequencer implements MessageHandler, ReplyHandler { private final MessageHandler sender; private final Map<Long, Queue<Message>> seqMap = new HashMap<>(); private final Messenger msn; - private final static Object BUSY = new Object(); - private final static ThreadLocal<Object> isSending = new ThreadLocal<>(); + private final static ThreadLocal<Boolean> isSending = new ThreadLocal<>(); /** * Constructs a new sequencer on top of the given async sender. @@ -163,15 +162,15 @@ public class Sequencer implements MessageHandler, ReplyHandler { } } if (msg != null) { - Object alreadySending = isSending.get(); - if ((alreadySending == BUSY) && (msn != null)) { + Boolean alreadySending = isSending.get(); + if ((alreadySending == Boolean.TRUE) && (msn != null)) { // Dispatch in another thread to break possibly very long recursion. msn.enqueue(new SequencedSendTask(msg)); } else { - isSending.set(BUSY); + isSending.set(Boolean.TRUE); sequencedSend(msg); } - isSending.set(null); + isSending.set(Boolean.FALSE); } } |