文章来源：隔叶黄莺Unmi Blog 当我们在使用 Java 8 的 Lambda 表达式时，表达式内容需要抛出异常，也许还会想当然的让当前方法再往外抛来解决编译问题，如下面的代码：
让main()方法抛出Exception还是不解决决编译错误，仍然提示 "Unhandled exception: java.io.FileNotFoundException"。 因为我们可能保持着惯性思维，忽略了 Lambda 本身就是一个功能性接口方法的实现，所以把上面的代码还原为匿名类的方式 那么对于上面那种情况应该如何处理呢？ 就地处决或转换为 unchecked 异常现在我们就不会让foo()方法去抛出一个异常来捕获new FileInputStream(s).close()这一行可能出现的异常，一定是会让accept()方法来向外层抛异常，正是因为Consumer定义的accept()方法定义不抛异常，所以若是用 IntelliJ IDEA 的话, 它会提示我们把会产生异常的那行 catch 起来，像下面那样： 使用声明了异常的 SAM，可在外层方法继续抛出如果不想要捕获异常再转换为 unchecked exception 的话，那就不能用 Java 8 内置的Consumer接口了，需要有一个声明抛出 Exception 的 accept()方法的Consumer. 比如下面的定义的MyConsumer, 它的accept()方法抛出异常，代码如下： 上面的foo()和client()方法就可以声明抛出由new FileInputStream()产生的异常，而不需要进行异常转换。 并发操作是 Lambda 的异常处理在单线程模式下，异常还是容易处理，有异常时在当前线程的异常栈中能查找到, 而对于其他线程中抛出的异常在当前线程中是无法捕获到的，就像下面的尝试是不会成功的 在我的测试下控制台的输出类似如下： Exception in thread "Thread-0" java.lang.RuntimeException: Something wrong at cc.unmi.TestLambdaException.lambda$bar$1(TestLambdaException.java:41) at java.lang.Thread.run(Thread.java:745) 那么 Java 8 的 parallelStream() 会把任务分配到其他线程去执行，是不是也无法在调用者线程上捕获到parallelStream().forEach(Consumer)中抛出的异常呢？不是的，可正常捕获，因为 Java 8 的ForkJoinTask有进行特殊的处理，会在子线程发生异常时把子线程的异常附着到调用者线程上去。我们来运行下面的代码： 总之，在使用 Java 8 集合框架的 parallelStream() 可以正常的在启动线程中捕获到 Lambda 表达式中产生的异常。 由上图中可看到起关键作用的就是ForkJoinTask的invoke(), reportException(), 和 getThrowableException()方法，可以大概看下相关的java.util.concurrent.ForkJoinTask代码片断： 这可以作为我们在实际的多线程应用中异常处理的一个参考。 补充能量，回顾阅读： |
注册
登录
