Fix QueueStats to use a ConcurrentMap Since this accessed by multiple threads, use a thread-safe structure. Change-Id: I5db7426fee2a94eee63dd811656da4895828a924
diff --git a/src/main/java/com/googlesource/gerrit/plugins/quota/QueueStats.java b/src/main/java/com/googlesource/gerrit/plugins/quota/QueueStats.java index ebf2f8a..cddfce1 100644 --- a/src/main/java/com/googlesource/gerrit/plugins/quota/QueueStats.java +++ b/src/main/java/com/googlesource/gerrit/plugins/quota/QueueStats.java
@@ -15,8 +15,8 @@ package com.googlesource.gerrit.plugins.quota; import java.util.Arrays; -import java.util.HashMap; import java.util.Map; +import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; @@ -50,7 +50,7 @@ } } - public static Map<Queue, AtomicInteger> availableThreadsPerQueue = new HashMap<>(); + public static Map<Queue, AtomicInteger> availableThreadsPerQueue = new ConcurrentHashMap<>(); public static void initQueueWithCapacity(Queue q, int c) { availableThreadsPerQueue.put(q, new AtomicInteger(c));