Java ExecutorService.awaitTermination()是否会阻塞主线程等待？

你观察到的执行顺序完全符合ExecutorService的接口规范，不存在API行为异常，核心是两个用法错误。

• 调用顺序错误：awaitTermination方法的生效前提是线程池已经先收到关闭请求，这个方法的作用是在发起关闭后阻塞等待，而非在池子正常运行时等待任务跑完。你是先调用awaitTermination、后调用shutdown()，前者根本不会进入等待任务的逻辑。
• 参数设置错误：你给awaitTermination传入的超时参数是0L, TimeUnit.SECONDS，按照接口规范，当传入的超时时间小于等于0时，方法不会做任何等待，只会立刻检测当前线程池是否已经完全终止，直接返回检测结果的布尔值。
• 额外的认知偏差：shutdown()方法本身也不会阻塞主线程，它的作用仅仅是向线程池发送指令：停止接收新任务，将已提交到队列的任务全部执行完毕后关闭线程池，指令发送完成后方法会立刻返回，不会等待任务执行结束。

你的代码执行逻辑完全符合上述规则：

1. 提交任务后调用awaitTermination(0L, TimeUnit.SECONDS)，因为既没有提前发起shutdown、超时时间又是0，方法瞬间返回false，不做任何阻塞
2. 接着调用shutdown()，发送完关闭指令后方法立刻返回
3. 主线程直接执行到打印分割线的语句，最先输出-----------
4. 线程池里的工作线程此时才开始执行已提交的任务，依次输出run begins、休眠1秒、输出run ends，和你看到的运行结果完全一致。

标准流程是先提交所有任务，再发起shutdown，最后调用awaitTermination传入合理的超时时间阻塞等待，修正后的代码如下：

ExecutorService executor = Executors.newFixedThreadPool(3);
executor.execute(new Runnable() {
  @Override
  public void run() {
    try {
      System.out.println("run begins");
      Thread.sleep(1000);
      System.out.println("run ends");
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
  }
});
// 先发起关闭请求，拒绝新任务提交
executor.shutdown();
try {
  // 阻塞等待，设置足够长的超时时间，直到所有任务执行完成/超时/线程被中断
  boolean allTasksDone = executor.awaitTermination(10L, TimeUnit.SECONDS);
  if (allTasksDone) {
    System.out.println("线程池所有任务已执行完毕");
  } else {
    System.out.println("等待超时，仍有任务未执行完成");
  }
} catch (InterruptedException e) {
  e.printStackTrace();
}
System.out.println("-----------");

这段代码的输出顺序会符合预期：先打印run begins，1秒后打印run ends，再打印任务完成提示，最后打印分割线。

如果不想关闭线程池，只是要感知某一批任务全部执行完成，可以选择以下方案：

• 用submit()提交任务，拿到返回的Future实例，调用Future.get()方法会阻塞直到对应任务执行完成
• 批量提交任务时使用invokeAll()方法，该方法会阻塞直到所有提交的任务全部执行完成
• 借助CountDownLatch等同步工具类，初始化时传入任务总数，每个任务执行结束时调用countDown()，主线程调用await()阻塞直到计数归零，即可感知所有任务跑完。

内容的提问来源于stack exchange，提问作者Troskyvs