Fixes #1186 limit the number of items in the ThreadLocal list in the ConcurrentBag.

7 years ago · 52b3811e4d
parent d0cb0f8dab
commit 52b3811e4d
1 changed files with 3 additions and 1 deletions
--- a/src/main/java/com/zaxxer/hikari/util/ConcurrentBag.java
+++ b/src/main/java/com/zaxxer/hikari/util/ConcurrentBag.java
@ -195,7 +195,9 @@ public class ConcurrentBag<T extends IConcurrentBagEntry> implements AutoCloseab
      }

      final List<Object> threadLocalList = threadList.get();
-      threadLocalList.add(weakThreadLocals ? new WeakReference<>(bagEntry) : bagEntry);
+      if (threadLocalList.size() < 50) {
+         threadLocalList.add(weakThreadLocals ? new WeakReference<>(bagEntry) : bagEntry);
+      }
   }

   /**