ExecutorService.awaitTermination（）永不超时

Question

我试图实现一个功能，其中或者可以在规定的时间内完成可调参数或者操作超时。我曾希望ExecutorService.awaitTermination()会这样做，但很惊讶地发现它没有。代码如下。运行永不完成。

public class Counter implements Callable<Void> { 

    public static void main(String[] args) throws InterruptedException { 
     final Map<String, Counter> map = new HashMap<>(); 
     map.put("", new Counter()); 
     final Map<String, Future<Void>> result = executeTasksInParallel(map); 
     final Future<Void> voidFuture = result.get(""); 
     try { 
      voidFuture.get(); 
     } catch (Exception e) { 
      e.printStackTrace(); 
     } 
    } 

    @Override 
    public Void call() throws Exception { 
     for (long i = 0L; i < Long.MAX_VALUE; i++); 
     return null; 
    } 

    public static <K, V> Map<K, Future<V>> executeTasksInParallel(final Map<K, ? extends Callable<V>> callablesById) throws InterruptedException { 
     final Map<K, Future<V>> resultFuturesById = new HashMap<>(); 
     final ExecutorService executorService = Executors.newFixedThreadPool(callablesById.size()); 
     for (final Map.Entry<K, ? extends Callable<V>> callableByIdEntry : callablesById.entrySet()) { 
      final K id = callableByIdEntry.getKey(); 
      final Callable<V> callable = callableByIdEntry.getValue(); 
      final Future<V> resultFuture = executorService.submit(callable); 
      resultFuturesById.put(id, resultFuture); 
     } 
     executorService.shutdown(); 
     executorService.awaitTermination(5L, TimeUnit.SECONDS); 
     return resultFuturesById; 
    } 
} 

我在这里错过了什么吗？谢谢！

UPDATE：

我试着用下面替换try块内容，以堵塞避免的Future.get（），但是这并没有帮助

if (voidFuture.isDone()) { 
    voidFuture.get(); 
} 

Answer 1

1. 使用shutdownNow()乔C已指定...
2. ...但它只会通过检查当前线程的工作，如果你在call()代码允许它，例如被中断。见例如this question及其答案的详细信息。如果通过抛出InterruptedException（例如Thread.sleep(...)，Object.wait(...),Future.get(...)，对实现了InterruptibleChannel等的通道进行阻塞操作），有时您可能会在循环中直接或间接调用处理中断请求的方法， 。 编辑： ...并且如果InterruptedException被抛出不被抑制。
3. 是的，如果将来isDone()（因为它的主线程不是由您的executorService管理），只能拨打get()。

最终代码会

public class Counter implements Callable<Void> { 

    public static void main(String[] args) throws InterruptedException { 
     final Map<String, Counter> map = new HashMap<>(); 
     map.put("", new Counter()); 
     final Map<String, Future<Void>> result = executeTasksInParallel(map); 
     final Future<Void> voidFuture = result.get(""); 
     try { 
      if (voidFuture.isDone()) { 
       voidFuture.get(); 
      } 
     } catch (Exception e) { 
      e.printStackTrace(); 
     } 
    } 

    @Override 
    public Void call() throws Exception { 
     for (long i = 0L; i < Long.MAX_VALUE; i++) { 
      if (Thread.currentThread().isInterrupted()) { 
       Thread.currentThread().interrupt(); // restore interrupted flag 
       return null; 
      } 
      /* or e.g. throw an exception */ 
     } 
     return null; 
    } 

    public static <K, V> Map<K, Future<V>> executeTasksInParallel(
      final Map<K, ? extends Callable<V>> callablesById) 
      throws InterruptedException { 
     final Map<K, Future<V>> resultFuturesById = new HashMap<>(); 
     final ExecutorService executorService = 
      Executors.newFixedThreadPool(callablesById.size()); 
     for (final Map.Entry<K, ? extends Callable<V>> callableByIdEntry : callablesById 
      .entrySet()) { 
      final K id = callableByIdEntry.getKey(); 
      final Callable<V> callable = callableByIdEntry.getValue(); 
      final Future<V> resultFuture = executorService.submit(callable); 
      resultFuturesById.put(id, resultFuture); 
     } 
     executorService.shutdown(); 
     executorService.awaitTermination(5L, TimeUnit.SECONDS); 
     executorService.shutdownNow(); 
     return resultFuturesById; 
    } 
} 

Answer 2

文件awaintTermination的：

阻塞，直到关闭请求或超时发生后所有任务都已完成执行，或当前线程中断，以先发生者为准。

它会在5秒后完成，但生成的线程仍然在工作，它不是一个守护进程线程，所以你的代码将继续工作，直到子线程终止。

而voidFuture.get()将会阻塞直到返回。

Answer 3

awaitTermination()不会尝试杀死正在运行的任务。一旦awaitTermination()完成，你应该打电话shutdownNow()试图杀死仍然存在的东西。

https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html#shutdownNow()