FutureTask 本身不支持直接注册异常拦截器，需通过外部包裹异常处理逻辑，结合其状态控制与 get() 异常传播特性，实现长事务中子任务的异常捕获、分类、重试或降级。
futuretask 本身不支持直接注册异常拦截器，它没有回调钩子或事件监听机制。所谓“配合自定义异常拦截器”，本质是**在调用链中主动包裹异常处理逻辑**，结合 futuretask 的状态控制与 get() 方法的异常传播特性，实现对长事务关键节点的异常捕获、分类、重试或降级。这不是给 futuretask “加拦截器”，而是用它作为可观察、可取消的执行载体，在外部构建一套轻量但可控的异常治理层。
明确 FutureTask 在长事务中的角色定位
在大型分布式长事务（如跨服务订单创建+库存扣减+支付预占+消息投递）中，FutureTask 不应承担编排职责，而应聚焦于：
- 单点任务封装：将一个具备明确输入/输出、可能失败、需超时控制的子操作（如“调用库存服务扣减”）封装为 FutureTask
- 状态可观测性：通过 isDone()、isCancelled()、get(timeout) 实时感知该子任务是否完成、是否被中断、是否超时
- 执行可干预性：在事务协调层根据业务规则决定是否 cancel(true) 中断正在执行的耗时子任务（例如下游已返回失败，无需再等库存接口超时）
构建异常分类与响应策略层
FutureTask.get() 只抛出三种受检/非受检异常：InterruptedException、ExecutionException、TimeoutException。你需要围绕这三类做分级拦截：
- InterruptedException：说明协调线程被中断（如全局事务超时、用户主动取消）。应立即终止后续所有 FutureTask，并触发补偿动作（如回滚已提交的本地事务）
- TimeoutException：表明子任务未在预期时间内响应。需判断是否重试（幂等接口可重试）、降级（跳过非核心步骤）、或标记事务失败
-
ExecutionException：核心异常源。必须调用 getCause() 解包，再按异常类型路由到不同处理器：
✓ BusinessException（如库存不足）→ 触发业务补偿流程
✓ RemoteAccessException（如网络抖动）→ 加入重试队列（最多2次）
✓ RuntimeException（如 NPE）→ 记录告警，人工介入
代码结构示例：带上下文感知的 FutureTask 执行模板
避免每个地方都写重复的 try-catch，封装一个通用执行器：
public class TransactionalFutureExecutor {
private final ExecutorService executor;
public TransactionalFutureExecutor(ExecutorService executor) {
this.executor = executor;
}
public <T> T executeWithPolicy(
Callable<T> task,
String stepName,
Duration timeout,
BiFunction<Throwable, String, TransactionAction> exceptionHandler) {
FutureTask<T> futureTask = new FutureTask<>(task);
executor.execute(futureTask);
try {
return futureTask.get(timeout.toMillis(), TimeUnit.MILLISECONDS);
} catch (TimeoutException e) {
futureTask.cancel(true); // 中断执行线程
return handleException(e, stepName, exceptionHandler);
} catch (ExecutionException e) {
futureTask.cancel(false); // 已失败，无需中断
return handleException(e, stepName, exceptionHandler);
} catch (InterruptedException e) {
futureTask.cancel(true);
Thread.currentThread().interrupt();
throw new TransactionAbortException("事务被中断", e);
}
}
private <T> T handleException(
Throwable ex,
String stepName,
BiFunction<Throwable, String, TransactionAction> handler) {
TransactionAction action = handler.apply(ex, stepName);
switch (action.getType()) {
case RETRY:
return executeWithPolicy(action.getRetryTask(), stepName, action.getTimeout(), handler);
case RETURN_DEFAULT:
return (T) action.getDefaultValue();
case ABORT:
throw new TransactionAbortException("步骤 " + stepName + " 异常，终止事务", ex);
default:
throw new RuntimeException(ex);
}
}
}
使用时只需传入业务逻辑、超时策略和异常路由规则，不再散落异常处理代码。
与 CompletableFuture 的协同建议
FutureTask 适合封装**单个、需要强控制（取消/超时）的底层原子操作**；而长事务的整体编排建议交给 CompletableFuture 链式组合。例如：
- 用 FutureTask 封装“调用支付网关”并设置 8s 超时，失败后由其异常处理器决定是否走备用通道
- 用 CompletableFuture.supplyAsync(...).thenCompose(...) 编排“创建订单 → 扣库存 → 发消息”整个流程，其中每个环节内部调用上述 TransactionalFutureExecutor
- 这样既保留了 FutureTask 对子任务的精细掌控力，又利用 CompletableFuture 实现了高可读、可组合、非阻塞的高层流程
