diff --git a/src/main/java/com/zaxxer/hikari/util/ConcurrentBag.java b/src/main/java/com/zaxxer/hikari/util/ConcurrentBag.java index ee43276e..75331544 100644 --- a/src/main/java/com/zaxxer/hikari/util/ConcurrentBag.java +++ b/src/main/java/com/zaxxer/hikari/util/ConcurrentBag.java @@ -74,12 +74,7 @@ public class ConcurrentBag(); this.synchronizer = new Synchronizer(); - this.threadList = new ThreadLocal>() { - protected LinkedList initialValue() - { - return new LinkedList<>(); - } - }; + this.threadList = new ThreadLocal>(); } /** @@ -94,7 +89,13 @@ public class ConcurrentBag list = threadList.get(); + LinkedList list = threadList.get(); + if (list == null) + { + list = new LinkedList<>(); + threadList.set(list); + } + while (!list.isEmpty()) { final T reference = list.removeFirst();