diff --git a/redisson/src/main/java/org/redisson/connection/pool/ConnectionPool.java b/redisson/src/main/java/org/redisson/connection/pool/ConnectionPool.java index d1a499cfb..2e8bbd1e7 100644 --- a/redisson/src/main/java/org/redisson/connection/pool/ConnectionPool.java +++ b/redisson/src/main/java/org/redisson/connection/pool/ConnectionPool.java @@ -111,6 +111,7 @@ abstract class ConnectionPool { createConnection(entry, promise); promise.whenComplete((conn, e) -> { if (e == null) { + conn.decUsage(); if (!initPromise.isDone()) { entry.addConnection(conn); } else { @@ -279,6 +280,7 @@ abstract class ConnectionPool { return; } + promise.thenApply(c -> c.incUsage()); connectedSuccessful(entry, promise, conn); }); }