优化client

src/main/java/org/redkale/cluster/CacheClusterAgent.java

@@ -130,14 +130,14 @@ public class CacheClusterAgent extends ClusterAgent implements Resourcable {
                 checkApplicationHealth();
                 checkHttpAddressHealth();
                 loadSncpAddressHealth();
-                localEntrys.values().stream().filter(e -> !e.canceled).forEach(entry -> {
+                localEntrys.values().stream()
-                    checkLocalHealth(entry);
+                    .filter(e -> !e.canceled)
-                });
+                    .forEach(this::checkLocalHealth);
-                remoteEntrys.values().stream().filter(entry -> "SNCP".equalsIgnoreCase(entry.protocol)).forEach(entry -> {
+                remoteEntrys.values().stream()
-                    updateSncpAddress(entry);
+                    .filter(entry -> "SNCP".equalsIgnoreCase(entry.protocol))
-                });
+                    .forEach(this::updateSncpAddress);
             } catch (Exception e) {
-                logger.log(Level.SEVERE, "scheduleAtFixedRate check error", e instanceof CompletionException ? ((CompletionException) e).getCause() : e);
+                logger.log(Level.SEVERE, "scheduleAtFixedRate check error", e);
             }
         };
     }

src/main/java/org/redkale/net/AsyncNioCompletionHandler.java

@@ -67,7 +67,7 @@ class AsyncNioCompletionHandler<A> implements CompletionHandler<Integer, A>, Run
     @Override
     public void completed(Integer result, A attach) {
         ScheduledFuture future = this.timeoutFuture;
-        if (future != null) {
+        if (future != null && !future.isDone()) {
             this.timeoutFuture = null;
             future.cancel(true);
         }
@@ -95,7 +95,7 @@ class AsyncNioCompletionHandler<A> implements CompletionHandler<Integer, A>, Run
     @Override
     public void failed(Throwable exc, A attach) {
         ScheduledFuture future = this.timeoutFuture;
-        if (future != null) {
+        if (future != null && !future.isDone()) {
             this.timeoutFuture = null;
             future.cancel(true);
         }

src/main/java/org/redkale/net/client/Client.java

@@ -137,8 +137,10 @@ public abstract class Client<C extends ClientConnection<R, P>, R extends ClientR
                 try {
                     R req = pingRequestSupplier.get();
                     if (req == null) { //可能运行中进行重新赋值
-                        timeoutFuture.cancel(true);
+                        if (timeoutFuture != null && !timeoutFuture.isDone()) {
-                        timeoutFuture = null;
+                            timeoutFuture.cancel(true);
+                            timeoutFuture = null;
+                        }
                         return;
                     }
                     long now = System.currentTimeMillis();