Java中不能用do-while直接配合CompletableFuture，而应通过递归式CompletableFuture链模拟其“先执行、再判断”语义，实现异步重试，避免阻塞。
Java 中 do-while 是同步控制结构，而 CompletableFuture 是异步编程模型，二者不能直接“配合”执行（比如在 do-while 循环体中阻塞等待 CompletableFuture 完成），否则会破坏异步非阻塞的本质，甚至导致线程饥饿。但你可以用 CompletableFuture 的链式异步重试逻辑来**模拟 do-while 的“先执行、再判断”语义**，即：至少尝试一次，失败后根据条件决定是否重试，全部过程保持异步。
核心思路：用递归式 CompletableFuture 链替代循环
不写 do-while，而是定义一个返回 CompletableFuture<t></t> 的方法，在其内部：先发起一次异步任务；若成功，直接完成；若失败且满足重试条件，则异步调用自身（递归），否则以异常或默认值结束。
- 避免调用
.join()或.get()，防止阻塞线程池 - 重试间隔建议用
CompletableFuture.delayedExecutor()+thenComposeAsync() - 需显式控制最大重试次数，防止无限递归
基础异步重试模板（带次数限制与延迟）
以下是一个通用的 retryAsync 工具方法：
public static <T> CompletableFuture<T> retryAsync(
Supplier<CompletableFuture<T>> task,
int maxRetries,
long delayMs,
Predicate<Throwable> shouldRetry) {
<pre class="brush:php;toolbar:false;">return attempt(task, maxRetries, delayMs, shouldRetry, 0);}
立即学习“Java免费学习笔记（深入）”；
分析 Java Spring Boot 后端 Controller 代码，自动生成 Markdown 格式的接口文档。当用户说“生成 Java 接口文档”、“生成 API 文档”、“从 Spring 代码生成文档”时触发。
private static
return task.get()
.handle((result, ex) -> {
if (ex == null) {
return CompletableFuture.completedFuture(result);
} else if (attemptCount < maxRetries && shouldRetry.test(ex)) {
// 满足重试条件：延迟后递归重试
return CompletableFuture
.delayedExecutor(delayMs, TimeUnit.MILLISECONDS)
.apply(() -> attempt(task, maxRetries, delayMs, shouldRetry, attemptCount + 1));
} else {
// 不重试，包装原始异常
return CompletableFuture.failedFuture(ex);
}
})
.thenCompose(Function.identity());}
使用示例（HTTP 调用失败时最多重试 2 次，每次间隔 1 秒）：
CompletableFuture<String> result = retryAsync(
() -> callExternalApi(), // 异步任务（返回 CF）
2, // 最多重试 2 次（共执行 3 次）
1000, // 延迟 1s
ex -> ex instanceof IOException // 仅对 IO 异常重试
);
<p>result.thenAccept(System.out::println)
.exceptionally(e -> { System.err.println("最终失败: " + e); return null; });关键细节说明
-
“do-while 语义”的体现：第一次执行无条件发生（
task.get()），后续是否重试由handle中判断，符合“先做、再判”逻辑 -
延迟执行安全：用
delayedExecutor创建新调度器，避免占用原 CF 线程；不要用Thread.sleep()或Timer -
状态隔离：每次递归调用都携带当前
attemptCount，确保计数准确，不依赖外部变量 -
异常分类处理：通过
shouldRetry精确控制哪些异常值得重试（如网络超时可重试，401 认证错误则不应重试）
进阶：支持退避策略与上下文透传
如需指数退避（如 1s → 2s → 4s），可将 delayMs 改为函数：LongUnaryOperator backoffDelay = n -> (long) Math.pow(2, n) * 1000，并在递归时传入 backoffDelay.applyAsLong(attemptCount)。
若需在重试间透传上下文（如 traceId、用户 ID），可将 Supplier<cf></cf> 扩展为 Function<map object>, CompletableFuture<t>></t></map>，并在每次递归时传递不变的 context map。
本质上，这不是“do-while 配合 CompletableFuture”，而是用函数式、非阻塞、声明式的方式重构了重试流程。它更健壮、可组合、易测试，也真正发挥了异步编程的优势。
