使用 Callable 和 Future 时程序不会退出

Question

IDE：IntelliJ
JDK：Java 11

在测试讲座中的示例代码时，我发现了一些非常奇怪的东西，即使没有任何循环，我的程序也不会停止！

import java.util.concurrent.Callable;

public class FindMaxTask implements Callable<Integer> {
    private int[] data;
    private int start;
    private int end;

    public FindMaxTask(int[] data, int start, int end) {
        this.data = data;
        this.start = start;
        this.end = end;
    }

    public Integer call() {
        int max = Integer.MIN_VALUE;
        for (int i = start; i < end; i++) {
            if (data[i] > max) {
                max = data[i];
            }
        }
        return max;
    }
}

这是一个实现Callable 接口的FindMaxTask，它在给定的数组范围内执行查找最大值。

public static void testCallable() throws ExecutionException, InterruptedException {
        final int dataSize = 10000;
        int[] data = new int[dataSize];
        Random random = new Random();

        for (int i = 0; i < dataSize; i++) {
            data[i] = random.nextInt(1000000);
        }

        FindMaxTask task0 = new FindMaxTask(data, 0, dataSize / 2);
        FindMaxTask task1 = new FindMaxTask(data, dataSize / 2, dataSize);

        ExecutorService service = Executors.newFixedThreadPool(2);

        Future<Integer> future0 = service.submit(task0);
        Future<Integer> future1 = service.submit(task1);

        int ret0 = future0.get();
        int ret1 = future1.get();

        System.out.println("ret0: " + ret0 + System.lineSeparator() + "ret1: " + ret1);
    }

这是 Main 类中的 testCallable 静态函数。

如果我在 main 函数中运行 testCallable 函数，程序会在控制台中打印每个 ret 值后停止。

这个问题与Callable或Future有关吗？ （我在打印 ret0,ret1 后尝试调试 future1.isDone() 的值为 true，所以显然 chlid 线程似乎没有被阻塞）
请告诉我为什么会发生这种情况

Answer 1

你必须关闭线程池。否则，您仍然有非守护线程在后台运行。在所有非守护线程都停止之前，JVM 不会退出。

ExecutorService service = Executors.newFixedThreadPool(2);
try {
    // do things with the executor service
} finally {
    service.shutdown();
}

如果你想阻塞直到所有任务完成，你可以使用awaitTermination，或者调用shutdown然后循环直到isTerminated返回true。如果您想尝试立即终止任何正在运行或排队的任务，您可以使用shutdownNow。