From e925b5ed7456011411776137a423c7f04157a501 Mon Sep 17 00:00:00 2001
From: kongweiguang <kongweiguang@icourt.cc>
Date: Tue, 20 Jun 2023 19:16:18 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8E=BB=E9=99=A4=E6=97=A0=E9=99=90=E9=87=8D?=
 =?UTF-8?q?=E8=AF=95=E6=96=B9=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../dromara/hutool/core/util/RetryUtil.java   | 36 ++-----------------
 .../hutool/core/util/RetryUtilTest.java       | 16 ---------
 2 files changed, 3 insertions(+), 49 deletions(-)

diff --git a/hutool-core/src/main/java/org/dromara/hutool/core/util/RetryUtil.java b/hutool-core/src/main/java/org/dromara/hutool/core/util/RetryUtil.java
index 37e482e2a..d76c0d6fc 100644
--- a/hutool-core/src/main/java/org/dromara/hutool/core/util/RetryUtil.java
+++ b/hutool-core/src/main/java/org/dromara/hutool/core/util/RetryUtil.java
@@ -7,6 +7,9 @@ import org.dromara.hutool.core.thread.ThreadUtil;
 
 import java.time.Duration;
 import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
 import java.util.function.BiPredicate;
 import java.util.function.Supplier;
 
@@ -112,37 +115,4 @@ public class RetryUtil {
 			.orElseGet(recover);
 	}
 
-
-	/**
-	 * 从不停止的执行方法
-	 *
-	 * @param run   执行方法
-	 * @param delay 间隔时间
-	 * @param isEx  true：出现异常继续执行；false：则出现异常跳出执行。
-	 */
-	public static void ofNeverStop(Runnable run, Duration delay, boolean isEx) {
-		while (true) {
-			try {
-				run.run();
-			} catch (Throwable e) {
-				if (!isEx) {
-					break;
-				}
-			} finally {
-				ThreadUtil.sleep(delay.toMillis());
-			}
-		}
-	}
-
-	/**
-	 * 从不停止的执行方法，异步执行
-	 *
-	 * @param run   执行方法
-	 * @param delay 间隔时间
-	 * @param isEx  true：出现异常继续执行；false：则出现异常跳出执行。
-	 */
-	public static void ofNeverStopAsync(Runnable run, Duration delay, boolean isEx) {
-		CompletableFuture.runAsync(() -> ofNeverStop(run, delay, isEx), GlobalThreadPool.getExecutor());
-	}
-
 }
diff --git a/hutool-core/src/test/java/org/dromara/hutool/core/util/RetryUtilTest.java b/hutool-core/src/test/java/org/dromara/hutool/core/util/RetryUtilTest.java
index 7b2629ed6..cda9d370e 100644
--- a/hutool-core/src/test/java/org/dromara/hutool/core/util/RetryUtilTest.java
+++ b/hutool-core/src/test/java/org/dromara/hutool/core/util/RetryUtilTest.java
@@ -72,20 +72,4 @@ public class RetryUtilTest {
 		Assertions.assertEquals("ok", result);
 	}
 
-
-	@Test
-	public void neverStop() {
-		//异步一直执行
-		RetryUtil.ofNeverStopAsync(() -> {
-			System.out.println("async -->");
-		}, Duration.ofSeconds(1), true);
-
-		System.out.println(" ================ ");
-		//同步一直执行
-		RetryUtil.ofNeverStop(() -> {
-			System.out.println(123);
-		}, Duration.ofSeconds(3), true);
-
-
-	}
 }