Как прервать поток с учетом объекта Future?

Question

Я хочу, чтобы запустить поток и отменить его, если он не заканчивается в течение 5 секунд:

private final class HelloWorker implements Callable<String> { 
    public String call() throws Exception { 
     while(true) { 
      if (Thread.isInterrupted()) { 
       return null; 
      } 
     } 
     return performExpensiveComputation(); 
    } 

    private String performExpensiveComputation() { 
     // some blocking expensive computation that may or may not take a very long time 
    } 
} 

private ExecutorService executorService = Executors.newFixedThreadPool(threadPoolSize); 
Future<String> future = executorService.submit(new HelloWorker()); 

try { 
    String s = future.get(5, TimeUnit.SECONDS); 
} catch (TimeoutException e) { 
    future.cancel(true); 

    System.out.println("cancelled: " + future.isCancelled() + "done: " + future.isDone()); 

    executorService.shutdown(); 

    try { 
     System.out.println("try to terminate: " + executorService.awaitTermination(60, TimeUnit.SECONDS)); 
    } catch (Exception ex) { 
     // ignore 
    } 
} 

Однако похоже, что awaitTermination возвращает ложь. Есть ли способ проверить, почему служба ExecutorService не будет завершена? Могу ли я выяснить, какие потоки еще запущены?

Answer 1

Безопасный способ остановки рабочей нити не нарушает стабильности остальной части процесса. Вот почему Thread#stop давно устарел, и почему в Executor Services используется только мягкий кооперативный механизм Thread#interrupt.

Ваш поток должен будет активно проверять, было ли запрошено прерывание и выполнить правильную очистку до окончания. В качестве альтернативы, поток будет вызывать некоторые прерывистые методы JDK, которые будут вызывать InterruptedException, который протектора будет правильно чтить и заканчивать сам.