obtrudeexception() 用于将异常强塞入一个已经完成的 completablefuture，使其状态变为 exceptionally。该操作会覆盖原有的结果或异常，并立即唤醒所有等待该任务完成的线程（如调用 join() 或 get() 的线程）。使用场景通常是：你持有一个已完成的任务引用，但业务逻辑需要强制将其标记为失败，以便下游的 exceptionally() 或 handle() 回调能捕获到错误。
obtrudeException() 对已完成任务的影响是什么
当 CompletableFuture 已经完成时，调用 obtrudeException() 会直接修改其内部状态，将结果替换为指定的异常。如果此时有线程阻塞在 get() 或 join() 上，它们会立刻抛出 CompletionException。需要注意的是，该方法不会触发 whenComplete() 等异步回调，只会影响同步获取结果的线程。
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
public class ObtrudeDemo {
public static void main(String[] args) throws ExecutionException, InterruptedException {
// 创建一个已完成的任务
CompletableFuture<String> future = CompletableFuture.completedFuture("Success");
// 尝试获取结果（正常情况）
System.out.println(future.join()); // 输出: Success
// 强塞异常
future.obtrudeException(new RuntimeException("Forced Failure"));
try {
future.join(); // 这里会抛出 CompletionException
} catch (Exception e) {
System.out.println(e.getCause().getMessage()); // 输出: Forced Failure
}
}
}obtrudeException() 与 completeExceptionally() 的区别
completeExceptionally() 只能在任务未完成时调用，如果任务已经完成，它会返回 false 且不做任何操作。而 obtrudeException() 无论任务是否完成，都会强行改变状态。因此，如果你不确定任务是否完成，且希望确保它处于异常状态，应使用 obtrudeException()；如果只希望在未成功时设置异常，则使用 completeExceptionally()。
立即学习“Java免费学习笔记（深入）”；
import java.util.concurrent.CompletableFuture;
public class CompareMethods {
public static void main(String[] args) {
CompletableFuture<String> completedFuture = CompletableFuture.completedFuture("Done");
CompletableFuture<String> pendingFuture = new CompletableFuture<>();
// 对已完成的任务调用 completeExceptionally
boolean result1 = completedFuture.completeExceptionally(new RuntimeException("Fail"));
System.out.println(result1); // 输出: false (因为已完成，无法覆盖)
// 对已完成的任务调用 obtrudeException
completedFuture.obtrudeException(new RuntimeException("Overridden"));
// 对未完成的任务调用 completeExceptionally
boolean result2 = pendingFuture.completeExceptionally(new RuntimeException("Pending Fail"));
System.out.println(result2); // 输出: true (成功设置异常)
}
}obtrudeException() 后如何正确捕获异常
调用 obtrudeException() 后，后续通过 join() 或 get() 获取结果时，会抛出 java.util.concurrent.CompletionException。你需要捕获这个包装异常，并通过 getCause() 获取原始异常。如果使用 exceptionally() 或 handle() 注册了回调，这些回调会在 obtrudeException() 调用后立即执行，传入的异常参数即为强塞的异常对象。
