diff --git a/hutool-core/src/main/java/org/dromara/hutool/core/thread/RetryUtil.java b/hutool-core/src/main/java/org/dromara/hutool/core/thread/RetryUtil.java index 60c9a2bc8..0371858d6 100644 --- a/hutool-core/src/main/java/org/dromara/hutool/core/thread/RetryUtil.java +++ b/hutool-core/src/main/java/org/dromara/hutool/core/thread/RetryUtil.java @@ -37,7 +37,7 @@ public class RetryUtil { * 没有返回值,重试执行方法 * * @param run 执行方法 - * @param maxAttempts 最大的重试次数 + * @param maxAttempts 最大的重试次数, 小于1不会重试, 但任务至少会被执行1次 * @param delay 重试间隔 * @param recover 达到最大重试次数后执行的备用方法 * @param exs 指定的异常类型需要重试 @@ -63,7 +63,7 @@ public class RetryUtil { * 有返回值,重试执行方法 * * @param sup 执行方法 - * @param maxAttempts 最大的重试次数 + * @param maxAttempts 最大的重试次数, 小于1不会重试, 但任务至少会被执行1次 * @param delay 重试间隔 * @param recover 达到最大重试次数后执行的备用方法 * @param exs 指定的异常类型需要重试 @@ -88,10 +88,10 @@ public class RetryUtil { * 没有返回值,重试执行方法 * * @param run 执行方法 - * @param maxAttempts 最大的重试次数 + * @param maxAttempts 最大的重试次数, 小于1不会重试, 但任务至少会被执行1次 * @param delay 重试间隔 * @param recover 达到最大重试次数后执行的备用方法 - * @param predicate 自定义重试条件 + * @param predicate 自定义重试条件, 返回true时表示重试 */ public static void ofPredicate(final Runnable run, final long maxAttempts, final Duration delay, final Supplier recover, final BiPredicate predicate) { @@ -105,14 +105,14 @@ public class RetryUtil { /** - * 根据异常信息进行重试 + * 根据自定义结果进行重试 * 有返回值,重试执行方法 * * @param sup 执行方法 - * @param maxAttempts 最大的重试次数 + * @param maxAttempts 最大的重试次数, 小于1不会重试, 但任务至少会被执行1次 * @param delay 重试间隔 * @param recover 达到最大重试次数后执行的备用方法 - * @param predicate 自定义重试条件 + * @param predicate 自定义重试条件, 返回true时表示重试 * @param 结果类型 * @return 执行结果 */ diff --git a/hutool-core/src/main/java/org/dromara/hutool/core/thread/RetryableTask.java b/hutool-core/src/main/java/org/dromara/hutool/core/thread/RetryableTask.java index 2189cf5d5..87eaf9d59 100644 --- a/hutool-core/src/main/java/org/dromara/hutool/core/thread/RetryableTask.java +++ b/hutool-core/src/main/java/org/dromara/hutool/core/thread/RetryableTask.java @@ -109,11 +109,11 @@ public class RetryableTask { */ private T result; /** - * 执行法方法 + * 执行方法 */ private final Supplier sup; /** - * 重试策略 + * 重试策略, 返回true时表示重试 */ private final BiPredicate predicate; /** @@ -150,8 +150,6 @@ public class RetryableTask { * @return 当前对象 */ public RetryableTask maxAttempts(final long maxAttempts) { - Assert.isTrue(this.maxAttempts > 0, "maxAttempts must be greater than 0"); - this.maxAttempts = maxAttempts; return this; } @@ -223,7 +221,8 @@ public class RetryableTask { private RetryableTask doExecute() { Throwable th = null; - while (--this.maxAttempts >= 0) { + // 任务至少被执行一次 + do { try { this.result = this.sup.get(); } catch (final Throwable t) { @@ -236,8 +235,11 @@ public class RetryableTask { break; } - ThreadUtil.sleep(delay.toMillis()); - } + // 避免最后一次任务执行时的线程睡眠 + if (this.maxAttempts > 0) { + ThreadUtil.sleep(delay.toMillis()); + } + } while (--this.maxAttempts >= 0); this.throwable = th; return this;