Jak zatrzymać zgłoszenie przesłane do ExecutorService?

Question

Próbuję zaimplementować przykładową aplikację do przetestowania interfejsów Callable i ExecutorService.

W moim app I oświadczyli:

ExecutorService exSvc = Executors.newSingleThreadExecutor(); 

Następnie:

Future<Integer> test = exSvc.submit(
    new Callable<Integer>() { 
     public Integer call() { 
      for(int i = 0; i < 1000; i++){ 
       System.out.println(i); 
      } 
      return 1; 
     } 
    }); 

Teraz staram się zatrzymać proces zanim zakończyć używam exSvc.shutdownNow() ale to nie robi praca.

Aby zatrzymać z wdziękiem klasyczny Thread, zwykle używam jakiejś zmiennej warunkowej . Jakie jest wspólne podejście do postępowania z ExecutorService?

Answer 1

Future.cancel(true) i ExecutorService.shutdownNow() przerwanie użycie nici. Tak długo, jak nie zrobić żródło połączeń zablokowania w swoim zadaniu, co potrzebne jest do obsługi stan przerwanej prawidłowo, coś takiego:

for(int i = 0; i < 1000; i++){ 
    // Uses isInterrupted() to keep interrupted status set 
    if (Thread.currentThread().isInterrupted()) { 
     // Cannot use InterruptedException since it's checked 
     throw new RuntimeException(); 
    } 
    System.out.println(i); 
} 

Jeśli się żródło połączenia blokujące (takie jak sieci IO), rzeczy stają się bardziej złożone, musisz je jakoś ręcznie przerwać, na przykład zamykając podstawowe gniazda.

Answer 2

Tak właśnie zrobiłbym z FixedThreadPool, mam nadzieję, że to pomoże.

ExecutorService pool = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors()); 

    List<Future<Void>> results = new ArrayList<>(); 

    for (int i = 0; i < numberOfJobs; i++) { 
     MyCallableJob job = new MyCallableJob (...); 
     results.add(pool.submit(job)); 
    } 

    for (Future<Void> result : results) { 
     try { result.get(); } 
     catch (InterruptedException | ExecutionException ignorable) { } 
    } 

    pool.shutdown();