From ce3fc5792bcccb4bc39c00f94987a12f650f99df Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Fri, 5 Jun 2020 17:52:09 +0800
Subject: [PATCH]

---
 src/org/redkale/cluster/ClusterAgent.java | 11 ++++-------
 1 file changed, 4 insertions(+), 7 deletions(-)

diff --git a/src/org/redkale/cluster/ClusterAgent.java b/src/org/redkale/cluster/ClusterAgent.java
index ac02c9539..02f07c067 100644
--- a/src/org/redkale/cluster/ClusterAgent.java
+++ b/src/org/redkale/cluster/ClusterAgent.java
@@ -48,6 +48,8 @@ public abstract class ClusterAgent {
 
     protected final ConcurrentHashMap<String, ClusterEntry> remoteEntrys = new ConcurrentHashMap<>();
 
+    protected long closeEndMaxTime;
+
     public void init(AnyValue config) {
         this.config = config;
         this.name = config.getValue("name", "");
@@ -124,13 +126,8 @@ public abstract class ClusterAgent {
 
     protected void afterDeregister(NodeServer ns, String protocol) {
         int s = intervalCheckSeconds();
-        if (s / 2 > 0) {  //暂停，弥补其他依赖本进程服务的周期偏差
-            try {
-                Thread.sleep(s * 1000 / 2);
-            } catch (InterruptedException ex) {
-            }
-            logger.info(this.getClass().getSimpleName() + " sleep " + s / 2 + "s after deregister");
-        }
+        long end = System.currentTimeMillis() + s * 1000 / 2; //暂停，弥补其他依赖本进程服务的周期偏差
+        if (end > this.closeEndMaxTime) this.closeEndMaxTime = end;
     }
 
     public int intervalCheckSeconds() {