java - 我是否需要在 future.get(); 之后使用 threadPool.awaitTermination

Question

我正在使用 ExecutorService 创建线程池。添加所有任务后，线程池关闭。

现在是 Future.get() 的 Java 文档说

Waits if necessary for the computation to complete, and then retrieves its result.

我无法理解“如果需要”部分。 future.get()方法什么时候等待以及等待多长时间？如果要等到线程执行结束，是否还需要threadPool.awaitTermination？

ExecutorService threadPool = Executors.newFixedThreadPool(numberOfThreads);
List<Future<?>> futureObjList = new ArrayList<Future<?>>();
for (int i = 0; i < numberOfThreads; i++) {
    ...
    Future<?> future = threadPool.submit(myThread);
    futureObjList.add(future);
    ...
}
threadPool.shutdown();

for(Future<?> future : futureObjList){
    try {
        future.get();
    } catch (Exception e1) {
        //if any thread fails, all other thread should stop their execution.
        threadPool.shutdownNow();
    }
}

try {
    threadPool.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLISECONDS);
} catch (InterruptedException e1) {
    throw e1;
}

Answer 1

“如果需要”只是意味着 get() 方法可能会阻塞或不阻塞，具体取决于 Runnable 或 Callable< 中发生的事情 是否已经完成。

假设您将 Callable 提交给执行程序服务。 Callable 需要 2 秒才能执行。

如果您在提交后 1 秒调用 get()，get() 将再阻塞 1 秒。但是，如果您在提交后 5 秒调用 get()，则 get() 不会阻塞并立即返回。