Java线程池异常捕获与任务失败重试策略

Java线程池有一个常见的陷阱：当任务抛出未捕获异常时，线程池并不会自动重试，任务会静默消失，甚至没有明显的错误提示。如果你期望失败后自动重试，那么很遗憾，线程池并未提供这种“保姆级”功能。开发者必须在任务内部手动实现一套机制：捕获异常 → 判断是否可重试 → 循环执行 → 加入延迟，否则任务丢失可能毫无察觉。

换言之，线程池（例如ExecutorService）仅负责将Runnable或Callable提交到线程中执行，它既不拦截异常，也不提供自动重试机制。一旦任务内部的异常未被捕获，当前线程将直接退出且没有任何反馈。这会导致什么后果？任务静默丢失！特别是当你使用submit()提交任务而不检查Future.get()的结果时，失败信息如同石沉大海。

重试逻辑必须在任务内部手动实现

正确的做法其实很简单：将业务逻辑封装在一个带循环和异常捕获的结构中。例如，使用while(attempt < maxRetries)作为外层循环框架，内部用try-catch包裹实际业务代码，遇到异常时判断是否达到重试上限，若未达到则继续循环。

• 正确做法：循环 + 捕获判断 + 延时，所有控制逻辑都保留在任务体内部。
• 错误做法：指望用submit()配合future.get()捕获异常后重新提交一个新任务——这会导致原任务的上下文（如局部变量、事务状态）丢失，相当于从头开始，与真正的“重试”大相径庭。
• 一个实用建议：每次重试前最好加上Thread.sleep(delay)，否则你很可能对下游服务发起DDOS攻击。

支持延迟与退避策略的重试封装

如果每次都在代码中硬写一套循环加睡眠，维护起来会非常痛苦。推荐的做法是抽取一个通用的重试工具类，将最大重试次数、基础延迟、是否启用指数退避等参数化配置。

• 定义一个接口RetryableTask，其中声明一个可能抛出异常的execute()方法。
• 实现一个RetryHandler，构造时传入maxAttempts和delay，内部通过for循环配合try-catch执行任务，失败后休眠指定时间再重试。
• 进阶玩法：引入随机抖动，例如delay * (0.8 + Math.random() * 0.4)，能够有效缓解多个客户端同时重试造成的“重试风暴”。

区分异常类型，避免无效重试

这里有一个关键点：并非所有异常都值得重试。盲目地对所有异常无脑重试，轻则加重故障，重则导致数据不一致（尤其是支付等非幂等操作，重复提交后果严重）。

• 适合重试的异常：网络超时（SocketTimeoutException）、连接拒绝（ConnectException）、临时限流（HTTP 429/503）——这些通常是短暂且可恢复的。
• 禁止重试的异常：参数错误（IllegalArgumentException）、业务校验失败（如余额不足）、非法状态（IllegalStateException）——这类异常重试一万次也无济于事，反而会拖垮系统。
• 实践中可以在catch块里使用instanceof判断异常类型，仅当匹配到可重试类型时才进入下一次循环，其余情况直接向上抛出或记录日志。

虚拟线程下的异常处理差异与注意事项

如果你已经开始使用虚拟线程（Thread.ofVirtual()），需要注意一个小陷阱：虚拟线程的未捕获异常默认会被JVM静默忽略，仅在stderr打印堆栈，极易被开发者忽略。因此，必须显式设置异常处理器。

• 务必调用setUncaughtExceptionHandler，将异常转发到你的日志系统或监控告警中。
• 即使使用了虚拟线程，重试逻辑依然需要写在任务体内部——虚拟线程并不改变“异常不会自动重试”这一基本原则。
• 好处是：单个虚拟线程崩溃不会影响载体线程，整体稳定性更高，但重试这个责任仍然在开发者肩上，没有捷径可走。