From ace03dd56ff730080788f20f3384ed0a00d6f045 Mon Sep 17 00:00:00 2001
From: Nikita Koksharov <nkoksharov@redisson.pro>
Date: Tue, 11 May 2021 08:07:59 +0300
Subject: [PATCH] refactoring

---
 .../org/redisson/connection/IdleConnectionWatcher.java    | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/redisson/src/main/java/org/redisson/connection/IdleConnectionWatcher.java b/redisson/src/main/java/org/redisson/connection/IdleConnectionWatcher.java
index 60028274b..75714f354 100644
--- a/redisson/src/main/java/org/redisson/connection/IdleConnectionWatcher.java
+++ b/redisson/src/main/java/org/redisson/connection/IdleConnectionWatcher.java
@@ -25,11 +25,11 @@ import org.redisson.pubsub.AsyncSemaphore;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.util.ArrayList;
 import java.util.Collection;
+import java.util.List;
 import java.util.Map;
-import java.util.Queue;
 import java.util.concurrent.ConcurrentHashMap;
-import java.util.concurrent.ConcurrentLinkedQueue;
 import java.util.concurrent.TimeUnit;
 import java.util.function.Function;
 import java.util.stream.Collectors;
@@ -58,7 +58,7 @@ public class IdleConnectionWatcher {
 
     };
 
-    private final Map<ClientConnectionsEntry, Queue<Entry>> entries = new ConcurrentHashMap<>();
+    private final Map<ClientConnectionsEntry, List<Entry>> entries = new ConcurrentHashMap<>();
     private final ScheduledFuture<?> monitorFuture;
 
     public IdleConnectionWatcher(ConnectionManager manager, MasterSlaveServersConfig config) {
@@ -97,7 +97,7 @@ public class IdleConnectionWatcher {
 
     public void add(ClientConnectionsEntry entry, int minimumAmount, int maximumAmount, Collection<? extends RedisConnection> connections,
                     AsyncSemaphore freeConnectionsCounter, Function<RedisConnection, Boolean> deleteHandler) {
-        Queue<Entry> list = entries.computeIfAbsent(entry, k -> new ConcurrentLinkedQueue<>());
+        List<Entry> list = entries.computeIfAbsent(entry, k -> new ArrayList<>(2));
         list.add(new Entry(minimumAmount, maximumAmount, connections, freeConnectionsCounter, deleteHandler));
     }