Merge pull request #131 from Netflix/refreshpool.1

don't queue tasks if queue is not empty
Netflix · Nov 9, 2022 · 4bdd49a · 4bdd49a
2 parents 047e055 + 82be6ab
commit 4bdd49a
Showing 1 changed file with 10 additions and 10 deletions.
diff --git a/evcache-core/src/main/java/com/netflix/evcache/pool/EVCacheClientPool.java b/evcache-core/src/main/java/com/netflix/evcache/pool/EVCacheClientPool.java
@@ -1482,17 +1482,17 @@ public void refreshPool() {
     public void refreshPool(boolean async, boolean force) {
         if (log.isDebugEnabled()) log.debug("Refresh Pool : async : " + async + "; force : " + force);
         try {
-            if(async) {
-                asyncRefreshExecutor.submit(new Runnable() {
-                    @Override
-                    public void run() {
-                        try {
-                            refresh(force);
-                        } catch (Exception e) {
-                            log.error(e.getMessage(), e);
+            if(async && asyncRefreshExecutor.getQueue().size() == 0) {
+                    asyncRefreshExecutor.submit(new Runnable() {
+                        @Override
+                        public void run() {
+                            try {
+                                refresh(force);
+                            } catch (Exception e) {
+                                log.error(e.getMessage(), e);
+                            }
                         }
-                    }
-                });
+                    });
             } else {
                 refresh(force);
             }