Future.get()与awaitTermination超时机制详解

知识点掌握了，还需要不断练习才能熟练运用。下面golang学习网给大家带来一个文章开发实战，手把手教大家学习《Future.get() 与 awaitTermination 超时机制解析》，在实现功能的过程中也带大家重新温习相关知识点，温故而知新，回头看看说不定又有不一样的感悟！

在使用 Future.get() 和 ExecutorService.awaitTermination() 时，多个超时设置会独立生效并可能累积阻塞时间。Future.get(timeout) 会阻塞当前线程直到单个任务完成或超时，而 awaitTermination(timeout) 则是在 shutdown() 后等待所有剩余任务终止。在串行调用 Future.get() 的场景下，总等待时间是所有 get() 超时与 awaitTermination 超时之和，而非最短超时生效。

1. Java并发中的任务执行与结果获取

在Java的并发编程中，ExecutorService 负责管理和执行任务，而 Future 接口则代表异步计算的结果。当我们将 Callable 任务提交给 ExecutorService 后，会返回一个 Future 对象，通过这个 Future 对象可以查询任务状态、取消任务或获取任务结果。

1.1 Future.get() 方法的阻塞特性

Future 接口提供了 get() 方法来获取任务的执行结果。其中，get(long timeout, TimeUnit unit) 方法允许我们设置一个超时时间。

• 阻塞行为： 调用 future.get(timeout, unit) 会阻塞当前线程，直到以下情况之一发生：
  • 任务成功完成并返回结果。
  • 指定的超时时间到达，此时会抛出 TimeoutException。
  • 任务在执行过程中抛出异常，此时 get() 会抛出 ExecutionException。
  • 当前线程被中断，此时会抛出 InterruptedException。
• 独立性： 每次对 Future 对象调用 get() 都是针对该特定任务的独立等待。如果存在多个 Future 对象，并且对它们依次调用 get()，那么这些 get() 调用将是串行阻塞的。

1.2 ExecutorService 的生命周期管理

ExecutorService 提供了方法来管理其生命周期，特别是任务的提交和服务的关闭。

• shutdown()： 此方法会启动一个有序的关闭过程。它会阻止新的任务被提交到 ExecutorService，但已经提交的任务（包括正在执行和等待执行的任务）会继续执行直到完成。
• awaitTermination(long timeout, TimeUnit unit)： 此方法在调用 shutdown() 之后使用。它会阻塞当前线程，直到所有已提交的任务都完成执行，或者指定的超时时间到达，或者当前线程被中断。该方法返回 true 表示所有任务都已终止，返回 false 表示超时发生但仍有任务未终止。

2. 案例分析：Future.get() 与 awaitTermination() 的超时交互

让我们分析一个典型的代码片段，来理解 Future.get() 的超时与 ExecutorService.awaitTermination() 的超时是如何共同作用的。

假设有如下代码（为清晰起见，我们将原始示例中对 Callable 调用 get() 的误用修正为对 Future 调用 get() 的常见模式）：

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;

public class TimeoutInteractionExample {

    public static void main(String[] args) throws InterruptedException, ExecutionException {
        // 1. 创建 ExecutorService，线程池大小为2
        ExecutorService executorService = Executors.newFixedThreadPool(2);

        // 2. 定义两个 Callable 任务
        Callable task1 = () -> {
            System.out.println("Task 1 started...");
            TimeUnit.MINUTES.sleep(3); // 模拟任务1执行3分钟
            System.out.println("Task 1 finished.");
            return "Result from Task 1";
        };

        Callable task2 = () -> {
            System.out.println("Task 2 started...");
            TimeUnit.MINUTES.sleep(4); // 模拟任务2执行4分钟
            System.out.println("Task 2 finished.");
            return "Result from Task 2";
        };

        // 3. 提交任务并获取 Future 对象
        List> futures = new ArrayList<>();
        futures.add(executorService.submit(task1));
        futures.add(executorService.submit(task2));

        // 4. 依次获取任务结果，设置5分钟超时
        long startTime = System.currentTimeMillis();
        System.out.println("Attempting to get results...");

        String result1 = null;
        try {
            result1 = futures.get(0).get(5, TimeUnit.MINUTES); // 获取 task1 结果，最长等待5分钟
            System.out.println("Result 1: " + result1);
        } catch (TimeoutException e) {
            System.out.println("Task 1 timed out after 5 minutes.");
        }

        String result2 = null;
        try {
            result2 = futures.get(1).get(5, TimeUnit.MINUTES); // 获取 task2 结果，最长等待5分钟
            System.out.println("Result 2: " + result2);
        } catch (TimeoutException e) {
            System.out.println("Task 2 timed out after 5 minutes.");
        }

        System.out.println("All get() calls completed.");

        // 5. 关闭 ExecutorService
        executorService.shutdown();
        System.out.println("ExecutorService shutdown initiated.");

        // 6. 等待 ExecutorService 终止，设置30秒超时
        try {
            boolean terminated = executorService.awaitTermination(30, TimeUnit.SECONDS); // 最长等待30秒
            if (terminated) {
                System.out.println("ExecutorService terminated successfully.");
            } else {
                System.out.println("ExecutorService did not terminate within 30 seconds.");
            }
        } catch (InterruptedException e) {
            System.out.println("awaitTermination was interrupted.");
        }

        long endTime = System.currentTimeMillis();
        System.out.println("Total elapsed time: " + (endTime - startTime) / 1000.0 + " seconds.");
    }
}

2.1 执行流程与超时计算

1. 任务提交 (executorService.submit(task)): task1 和 task2 被提交到线程池。由于线程池大小为2，这两个任务会立即开始并行执行。

   • task1 预计执行3分钟。
   • task2 预计执行4分钟。

2. 获取 task1 结果 (futures.get(0).get(5, TimeUnit.MINUTES)):

   • 主线程会阻塞，等待 task1 完成。
   • 由于 task1 实际执行3分钟，小于5分钟的超时时间，所以 get() 调用会在大约3分钟后成功返回。
   • 当前累计阻塞时间：约3分钟。

3. 获取 task2 结果 (futures.get(1).get(5, TimeUnit.MINUTES)):

   • 此调用在 task1 的 get() 返回之后才执行。主线程会再次阻塞，等待 task2 完成。

   • 由于 task2 实际执行4分钟，小于5分钟的超时时间，所以 get() 调用会在大约4分钟后成功返回。

   • 当前累计阻塞时间： (约3分钟 for task1) + (约4分钟 for task2) = 约7分钟。

   • 极端情况（如果任务超时）： 假设 task1 需要6分钟，task2 需要7分钟。

     • futures.get(0).get(5, TimeUnit.MINUTES) 会在5分钟后抛出 TimeoutException。
     • futures.get(1).get(5, TimeUnit.MINUTES) 会在接下来5分钟后抛出 TimeoutException。
     • 此时累计阻塞时间： 5分钟 + 5分钟 = 10分钟。

4. 关闭服务 (executorService.shutdown()):

   • shutdown() 方法被调用。此时，task1 和 task2 应该都已经完成（因为它们的 get() 调用已经成功返回，或者因超时而抛出异常，但任务本身仍在后台运行直到完成）。
   • ExecutorService 不再接受新任务。

5. 等待服务终止 (executorService.awaitTermination(30, TimeUnit.SECONDS)):

   • 此方法会阻塞主线程，最长等待30秒。它等待的是 shutdown() 调用时所有已提交但尚未终止的任务。
   • 在我们的例子中，如果 task1 和 task2 都已完成，并且没有其他未完成的后台任务，那么 awaitTermination 可能会立即返回 true。
   • 总最长阻塞时间：
     • 在任务均成功完成的情况下：约7分钟（3分钟 + 4分钟） + 几乎0秒（awaitTermination 立即返回）。
     • 在任务均超时的情况下（如上面极端情况）：10分钟（5分钟 + 5分钟） + 30秒 = 10分钟30秒。

结论： 在您原始的问题描述中，如果 Future.get() 调用是串行的，并且它们能够阻塞直到超时，那么最长的等待时间将是： task1.get() 的最长超时 (5分钟) + task2.get() 的最长超时 (5分钟) + awaitTermination() 的最长超时 (30秒) = 10分钟30秒。awaitTermination 的30秒是在前两个 get() 调用（最长10分钟）之后才开始计时的，因此它会叠加到总的阻塞时间上，而不是覆盖。

3. 注意事项与最佳实践

• 串行阻塞风险： 多个 Future.get() 串行调用会导致主线程累积阻塞时间。如果需要并行获取多个任务的结果，应考虑使用 CompletableFuture 或 ExecutorCompletionService，它们提供了更灵活的非阻塞或按完成顺序获取结果的机制。
• invokeAll() 的特性： 如果使用 executorService.invokeAll(List)，此方法本身会阻塞，直到所有任务完成或超时。它返回一个 List，这些 Future 上的 get() 调用通常会立即返回（除非 invokeAll 本身因超时而返回了未完成的 Future）。您原始代码中

今天关于《Future.get()与awaitTermination超时机制详解》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！