当可运行对象抛出异常时 Future<T>.get() 卡住 - 在单独的执行程序服务上运行时？

Question

这里有一个再现：

import java.util.concurrent.*;

public class Main {

    public static void main(String[] args) throws ExecutionException, InterruptedException {

        System.out.println("Hello!");

        ExecutorService exec = Executors.newSingleThreadExecutor();

        Future<Integer> f = exec.submit(() -> x());

        f.get();

        System.out.println("f.get() returned");

        exec.shutdownNow();

        System.out.println("Good bye!");

    }

    private static Integer x() {

        throw new RuntimeException("An unfortunate event");

    }

}

输出只显示“你好！” 和异常堆栈跟踪，然后让程序永远挂起。

下面的更改可以解决该问题，但是知道为什么执行会挂在上面的代码中吗？

使用公共线程池不会挂起：

Future<Integer> f = ForkJoinPool.commonPool().submit(() -> x());

将调用包装在 try/catch 周围可以让应用程序正常退出：

Future<Integer> f = exec.submit(() -> x());

try {

    f.get();

} catch (Exception ex) {

    ex.printStackTrace();

}

Answer 1

总是很难找到一个很好的例子try-finally及其适当的用法。我认为是这样。try {&nbsp; &nbsp; f.get();&nbsp; &nbsp; System.out.println("f.get() returned");} finally {&nbsp; &nbsp; exec.shutdownNow();}抛出的异常f.get();没有处理，主线程失败。但是该应用程序仍然包含ExecutorService您无法直接访问的非守护线程。