From a4c358dca346781ba236a8551ca6403e2702f9fe Mon Sep 17 00:00:00 2001
From: Toint <599818663@qq.com>
Date: Mon, 3 Mar 2025 17:28:58 +0800
Subject: [PATCH] =?UTF-8?q?=E9=87=8D=E8=AF=95=E5=B7=A5=E5=85=B7=E6=96=B0?=
 =?UTF-8?q?=E5=A2=9E=E8=8E=B7=E5=8F=96=E5=BC=82=E5=B8=B8=E6=96=B9=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../hutool/core/thread/RetryableTask.java     | 23 +++++++++++++++++++
 1 file changed, 23 insertions(+)

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 613f35831..f3f153290 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
@@ -124,6 +124,10 @@ public class RetryableTask<T> {
 	 * 重试间隔，默认1秒
 	 */
 	private Duration delay = Duration.ofSeconds(1);
+	/**
+	 * 异常信息
+	 */
+	private Throwable throwable;
 
 	/**
 	 * 构造方法，内部使用，调用请使用请用ofXXX
@@ -174,6 +178,24 @@ public class RetryableTask<T> {
 		return Optional.ofNullable(this.result);
 	}
 
+	/**
+	 * 获取结果, 如果无法获取结果, 则抛出最后一次执行时的异常
+	 *
+	 * @return 结果
+	 */
+	public T orElseThrow() throws Throwable {
+		return Optional.ofNullable(this.result).orElseThrow(() -> this.throwable().orElse(new RuntimeException()));
+	}
+
+	/**
+	 * 获取异常
+	 *
+	 * @return 返回包装了异常的 {@link Optional}对象
+	 */
+	public Optional<Throwable> throwable() {
+		return Optional.ofNullable(this.throwable);
+	}
+
 	/**
 	 * 异步执行重试方法
 	 *
@@ -216,6 +238,7 @@ public class RetryableTask<T> {
 			ThreadUtil.sleep(delay.toMillis());
 		}
 
+		this.throwable = th;
 		return this;
 	}