Fixed - connection leak during high load with few connections #5971

7 months ago · ce1f693590
parent 3c1c90f603
commit ce1f693590
1 changed files with 1 additions and 1 deletions
--- a/redisson/src/main/java/org/redisson/misc/AsyncSemaphore.java
+++ b/redisson/src/main/java/org/redisson/misc/AsyncSemaphore.java
@ -62,7 +62,7 @@ public final class AsyncSemaphore {
    private void tryForkAndRun() {
        if (executorService != null) {
            int val = tasksLatch.get();
-            if (stackSize.get() > 100 * val
+            if (stackSize.get() > 25 * val
                    && tasksLatch.compareAndSet(val, val+1)) {
                executorService.submit(() -> {
                    tasksLatch.decrementAndGet();