Merge pull request #516 from KamToHung/fix-515

[ISSUE #515] add scheduledFuture cancel check

Author: yanhom1314

common/src/main/java/org/dromara/dynamictp/common/util/ExecutorUtil.java

@@ -51,7 +51,7 @@ private static void tryPrintError(Runnable r, Throwable t) {
         if (r instanceof FutureTask) {
             try {
                 FutureTask<?> future = (FutureTask<?>) r;
-                if (future.isDone()) {
+                if (future.isDone() && !future.isCancelled()) {
                     future.get();
                 }
             } catch (InterruptedException e) {

test/test-core/src/test/java/org/dromara/dynamictp/test/core/thread/ScheduledDtpExecutorTest.java

@@ -29,6 +29,7 @@
 import org.springframework.test.context.junit.jupiter.SpringExtension;
 
 import java.time.LocalDateTime;
+import java.util.concurrent.ScheduledFuture;
 import java.util.concurrent.TimeUnit;
 
 @PropertySource(value = "classpath:/dynamic-tp-nacos-demo-dtp-dev.yml", factory = YamlPropertySourceFactory.class)
@@ -67,4 +68,14 @@ void testSubNotify() {
         dtpExecutor14.shutdownNow();
     }
 
+    @Test
+    void testScheduleCancel() {
+        ScheduledDtpExecutor dtpExecutor12 = (ScheduledDtpExecutor) DtpRegistry.getExecutor("dtpExecutor12");
+        ScheduledFuture<?> scheduledFuture = dtpExecutor12.scheduleWithFixedDelay(() -> {
+            System.out.println(Thread.currentThread().getName() + "进来了," +
+                    "当前时间是 ");
+        }, 0, 1000, TimeUnit.MILLISECONDS);
+        scheduledFuture.cancel(false);
+    }
+
 }