Java中for循环转Stream为何要求在forEach内处理已捕获异常？

我有一段运行正常的for循环代码，在try块中调用accountant.pay方法（会抛出BudgetIsOverException），外部catch可正常捕获该异常。但改用Stream API的forEach调用该方法时，即便外部有try-catch，仍被要求在forEach块内处理该异常，请问原因是什么？

原有for循环代码 #

try {
    Accountant accountant = getAccountant(employees);
    for (Employee person : employees) {
        accountant.pay(person, this); // throws BudgetIsOverException
    }
    allSalariesPaid = true;
}
catch (BudgetIsOverException e){
    allSalariesPaid = false;
}

改用Stream后的代码 #

try {
    Accountant accountant = getAccountant(employees);
    employees.stream()
             .forEach(e->accountant.pay(e,this)); // throws BudgetIsOverException
    allSalariesPaid = true;
}
catch (BudgetIsOverException e) {
    allSalariesPaid = false;
}

核心原因是Lambda表达式的异常处理规则与普通代码块存在本质差异：

• 普通for循环中，accountant.pay抛出的异常直接发生在try块的执行上下文里，属于当前线程的同一调用栈，外部的catch块可以直接捕获。
• 而forEach接收的是Consumer函数式接口，它的accept方法签名不允许抛出受检异常（checked exception）。你的BudgetIsOverException属于受检异常，Lambda里抛出它时，相当于违反了Consumer.accept的方法约定——因为Consumer的接口定义里没有声明任何受检异常，编译器会强制要求你在Lambda内部处理这个异常，否则就会报错。

简单来说：普通for循环的代码直接在try块作用域内执行，而Stream的forEach把代码放到了一个不允许抛出受检异常的函数式接口实现中，外部try-catch无法跨越这个接口边界捕获内部抛出的受检异常。

如果想要在外部捕获该异常，有两种常见可行方案：

1. 将受检异常包装为非受检异常抛出，让外部try-catch捕获包装后的异常：

try {
    Accountant accountant = getAccountant(employees);
    employees.stream()
             .forEach(e -> {
                 try {
                     accountant.pay(e, this);
                 } catch (BudgetIsOverException ex) {
                     throw new RuntimeException(ex); // 包装为运行时异常
                 }
             });
    allSalariesPaid = true;
} catch (RuntimeException e) {
    if (e.getCause() instanceof BudgetIsOverException) {
        allSalariesPaid = false;
    } else {
        throw e; // 其他异常继续抛出
    }
}

2. 自定义支持抛出受检异常的函数式接口，配合适配的遍历方法：
   先定义接口：

@FunctionalInterface
public interface ThrowingConsumer<T, E extends Exception> {
    void accept(T t) throws E;
}

再写适配工具方法：

public static <T, E extends Exception> void forEach(Stream<T> stream, ThrowingConsumer<T, E> consumer) throws E {
    for (T item : stream.toList()) {
        consumer.accept(item);
    }
}

使用时即可在外部直接捕获受检异常：

try {
    Accountant accountant = getAccountant(employees);
    forEach(employees.stream(), e -> accountant.pay(e, this));
    allSalariesPaid = true;
} catch (BudgetIsOverException e) {
    allSalariesPaid = false;
}

内容的提问来源于stack exchange，提问作者antnewbee