程序永远不会在 java 中的 TimeoutException 上结束

Question

我正在尝试一个 java 程序来理解 Future 的工作原理。

我编写了以下程序，但它永远不会结束。如果我在 Thread.sleep() 中输入一个小于 10 的值，那么它可以工作，但不适用于值 >=10。

我了解导致问题的部分可能是 future.get 调用。

但是，经过进一步分析，我尝试的是处理所有异常，而不是让 jvm 处理它们。

例如：

现在它终止了。

我做了进一步的检查，发现如果我抛出 ExecutionException 和 InterruptedException 并处理 TimeoutException 它再次正常工作。 这里奇怪的部分是我必须强制处理 TimeoutException，否则它将不起作用。我不太清楚为什么这种奇怪的行为会持续存在。

我使用的是 OpenJDK 15。

如果有人想尝试代码 sn-p 在这里：

import java.util.concurrent.*;

public class FixedThreadPoolExecutorDemo2 {

    public static void main(String[] args) throws ExecutionException, InterruptedException, TimeoutException {
        ExecutorService executorService = Executors.newFixedThreadPool(2);
        workWithFutureCallable(executorService);
        executorService.shutdownNow();
    }

    private static void workWithFutureCallable(ExecutorService executorService) throws ExecutionException, InterruptedException, TimeoutException {

        Future<Integer> myOtherFuture = executorService.submit(() -> {
            try {
                Thread.sleep(109);
            } catch (InterruptedException e) {
            }
            return 1000;
        });
        System.out.println("myOtherFuture  should be cancelled if running for more than specified time. ->" + myOtherFuture.get(10, TimeUnit.MILLISECONDS));

    }
}

Answer 1

TimeoutException 没有被main 捕获，所以main 也会突然终止没有调用shutdownNow。主线程已终止，但Executors创建的线程默认为非守护线程，因此虚拟机没有关闭，Executors线程继续运行。

解决方案：

    public static void main(String[] args) throws ExecutionException, InterruptedException, TimeoutException {
        ExecutorService executorService = Executors.newFixedThreadPool(2);
        try {
            workWithFutureCallable(executorService);
        } finally {
            executorService.shutdownNow();
        }
    }

或

实现ThreadFactory 来创建守护线程并使用它来获取服务：

        ExecutorService executorService = Executors.newFixedThreadPool(2, r -> {
            var thread = new Thread(r);
            thread.setDaemon(true);
            return thread;
        });

更好的是，至少在生产代码中，捕获并处理Exceptions（连同finally 块。）