summaryrefslogtreecommitdiffstats
path: root/messagebus
diff options
context:
space:
mode:
authorJon Marius Venstad <venstad@gmail.com>2021-03-15 14:41:51 +0100
committerJon Marius Venstad <venstad@gmail.com>2021-03-15 14:41:51 +0100
commit7fa03166ae8598bc8158b54f9f1756408fb1cefb (patch)
tree3cef39168392d5253d6dc5b0ece25c3682732851 /messagebus
parentcd8853bd1badc9713994c491b65467f8ba8d5554 (diff)
Use a map with better asymptotic behaviour, as comparable speed when small
Diffstat (limited to 'messagebus')
-rw-r--r--messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java b/messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java
index feec51643c4..99d9a6d6483 100644
--- a/messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java
+++ b/messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java
@@ -63,7 +63,7 @@ public class MessageBus implements ConfigHandler, NetworkOwner, MessageHandler,
private final AtomicBoolean destroyed = new AtomicBoolean(false);
private final ProtocolRepository protocolRepository = new ProtocolRepository();
private final AtomicReference<Map<String, RoutingTable>> tablesRef = new AtomicReference<>(null);
- private final CopyOnWriteHashMap<String, MessageHandler> sessions = new CopyOnWriteHashMap<>();
+ private final Map<String, MessageHandler> sessions = new ConcurrentHashMap<>();
private final Network net;
private final Messenger msn;
private final Resender resender;
@@ -72,7 +72,7 @@ public class MessageBus implements ConfigHandler, NetworkOwner, MessageHandler,
private int pendingCount = 0;
private int pendingSize = 0;
private final Thread careTaker = new Thread(this::sendBlockedMessages);
- private final ConcurrentHashMap<SendBlockedMessages, Long> blockedSenders = new ConcurrentHashMap<>();
+ private final Map<SendBlockedMessages, Long> blockedSenders = new ConcurrentHashMap<>();
public interface SendBlockedMessages {
/**