ExecutorService的invokeAll()方法在任务执行超时后，未完成的任务会被如何处理？ 如何安全地取消这些任务并回收资源？

Question

ExecutorService的invokeAll()方法在任务执行超时后，未完成的任务会被如何处理？ 如何安全地取消这些任务并回收资源？

Answer 1

阿里嘎多学长整理AIGC生成，因移动端显示问题导致当前答案未能完全显示，请使用PC端查看更加详细的解答过程

ExecutorService的invokeAll()方法在任务执行超时后，未完成的任务会被如何处理？

在Java的ExecutorService中，invokeAll()方法会返回一个Future数组，包含所有提交的任务的Future对象。这些Future对象可以用来检查任务是否已经完成，或者等待任务完成。

当任务执行超时后，未完成的任务会被ExecutorService自动取消。取消的任务会抛出CancellationException异常。

如何安全地取消这些任务并回收资源？

要安全地取消这些任务并回收资源，可以使用以下方法：

1. 使用Future.cancel(boolean mayInterruptIfRunning)方法，传入true参数，可以中断正在执行的任务。
2. 使用ExecutorService.shutdownNow()方法，关闭ExecutorService，取消所有正在执行的任务。
3. 使用try-catch-finally语句块，确保在任务取消后，资源被回收。

// 使用Future.cancel(boolean mayInterruptIfRunning)方法
Future<?>[] futures = executor.invokeAll(tasks);
for (Future<?> future : futures) {
    try {
        future.get(timeout, TimeUnit.SECONDS);
    } catch (InterruptedException | ExecutionException | TimeoutException e) {
        // 处理异常
    } finally {
        future.cancel(true); // 中断正在执行的任务
    }
}

// 使用ExecutorService.shutdownNow()方法
executor.shutdownNow();

注意：在使用ExecutorService时，需要确保任务是线程安全的，避免资源泄露。