如何等待ThreadPoolExecutor中的所有任务在超时时间内完成，而不关闭执行器？

Question

在使用ThreadPoolExecutor管理我的任务而不是为每个任务创建单独的线程之后。我使用以下部分等待特定数量的任务完成：

poolThreadsExecutor.shutdown();
poolThreadsExecutor.awaitTermination(10, TimeUnit.MINUTES);
for (Future<List<String>> future : futures) {
    if (!future.isDone()) {
       future.cancel(true);
    }
}

有了这个代码，我确保在运行的任务完成之前，没有新的任务可以提交。运行任务也有一个超时，之后我检查期货列表并取消任何任务，以防它被阻止。

有了这个解决方案，我就有了我想要的所有要点，但问题是执行器将在之后被销毁，我每次都必须创建一个新的执行器。

有没有可能在不关闭执行器的情况下获得相同的功能？

注：我也不能使用ConditDownLatch，因为任务的数量以前是未知的。

Answer 1

我不知道你是如何提交任务的。但我看到你有一份未来的清单。如果您可以一次提交所有任务，则可以使用：

futures = poolThreadsExecutor.invokeAll(tasks, 10, TimeUnit.MINUTES);

它将执行您的任务，直到所有任务完成或超时过期为止（未完成的任务将被取消）。

另外，来自番石榴的Futures.successfulAsList可能会有所帮助。

Answer 2

这将是一个解决方案的概要：

1. 计算任务完成的截止日期：截止日期=当前TimeMillis（）超时；
2. 循环遍历所有的期货，调用future.get（time左，MILLISECONDS），每次调整time左=截止日期-电流TimeMillis（）；
3. 如果到了最后期限，那么跳出这个循环，进入取消循环。

final long deadline = System.currentTimeMillis() + timeout;
for (Future<?> f : futures) {
  final long timeLeft = deadline - System.currentTimeMillis();
  if (timeLeft <= 0) break;
  try {
    f.get(timeLeft, TimeUnit.MILLISECONDS);
  } catch (TimeoutException e) {
     break;
  }
}

for (Future<?> f : futures) {
  if (!future.isDone()) {
     future.cancel(true);
  }
}