avoid unnecessary calls to ConcurrentLinkedDeque.size() which is a no…

…n-constant-time operation (#9922)
micronaut-projects · Sep 29, 2023 · 74097a6 · 74097a6
1 parent c8c9540
commit 74097a6
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/http-client/src/main/java/io/micronaut/http/client/netty/PoolResizer.java b/http-client/src/main/java/io/micronaut/http/client/netty/PoolResizer.java
@@ -225,7 +225,8 @@ final void onConnectionInactive2(ResizerConnection connection) {
     }
 
     final void addPendingRequest(PoolSink<ConnectionManager.PoolHandle> sink) {
-        if (pendingRequests.size() >= connectionPoolConfiguration.getMaxPendingAcquires()) {
+        int maxPendingAcquires = connectionPoolConfiguration.getMaxPendingAcquires();
+        if (maxPendingAcquires != Integer.MAX_VALUE && pendingRequests.size() >= maxPendingAcquires) {
             sink.tryEmitError(new HttpClientException("Cannot acquire connection, exceeded max pending acquires configuration"));
             return;
         }