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); - - - } }