From ce1f69359065a1820c7c26a7c83f4d7cbb61b827 Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Wed, 26 Jun 2024 11:07:27 +0300 Subject: [PATCH] Fixed - connection leak during high load with few connections #5971 --- redisson/src/main/java/org/redisson/misc/AsyncSemaphore.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/redisson/src/main/java/org/redisson/misc/AsyncSemaphore.java b/redisson/src/main/java/org/redisson/misc/AsyncSemaphore.java index d74a65d78..5dc71e29f 100644 --- 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();