From 53ff5913638deaa3ff6277f2e5aff1ba99e615e0 Mon Sep 17 00:00:00 2001 From: Violeta Georgieva Date: Thu, 30 Jan 2025 16:10:10 +0200 Subject: [PATCH] Ensure the permit is returned when the Borrower is cancelled Signed-off-by: Violeta Georgieva --- reactor-pool/src/main/java/reactor/pool/SimpleDequePool.java | 1 + 1 file changed, 1 insertion(+) diff --git a/reactor-pool/src/main/java/reactor/pool/SimpleDequePool.java b/reactor-pool/src/main/java/reactor/pool/SimpleDequePool.java index 84517d5..6702de5 100644 --- a/reactor-pool/src/main/java/reactor/pool/SimpleDequePool.java +++ b/reactor-pool/src/main/java/reactor/pool/SimpleDequePool.java @@ -415,6 +415,7 @@ private void drainLoop() { *=======================*/ Borrower borrower = pendingPoll(borrowers); if (borrower == null || borrower.get()) { + poolConfig.allocationStrategy().returnPermits(permits); continue; //we expect to detect pool is shut down in next round or the Borrower was cancelled } if (isDisposed()) {