ExecutorService, как узнать, когда все потоки закончены без блокировки основного потока?

Question

У меня есть многопоточная реализация, где я создаю ExecutorService и отправляю выполняемые задачи, я хочу знать, когда все потоки отправлены, завершились без блокировки основного потока и пользовательского интерфейса. Я пробовал ExecutorService.awaitTermination(), но он блокирует основной поток и пользовательский интерфейс. Я искал много, но я не могу найти элегантный способ сделать это. Я сейчас думаю о создании другого потока, который подсчитывает количество завершенных потоков и запускает событие, когда все закончится, но это не очень хороший подход, и мне нужно лучшее решение!

Answer 1

isTerminated() будет делать

к сведению, однако, что оба awaitTermination и isTerminated только даст вам значимый результат после того, как вы назвали shutdown

Answer 2

Использовать SwingWorker для отключения пула потоков и вызвать awaitTermination(). Это предотвратит блокировку пользовательского интерфейса и вызовет done() из потока отправки событий в вашей реализации SwingWorker, который вы можете использовать для запуска любых изменений пользовательского интерфейса, которые вам нужны.

Если вы хотите отслеживать потоки, выполняемые с помощью обновления пользовательского интерфейса, вы можете использовать рабочий поток, чтобы отслеживать это в цикле и вызывать publish() с аргументами, которые затем передаются в вашу реализацию process() на EDT.

Answer 3

Почему бы не использовать CountDownLatch, а затем уведомить основной поток, когда защелка выполнена.

Answer 4

Вы можете создать отдельный поток для отслеживания, когда экземпляр службы исполнитель выключается:

final ExecutorService execSvc = ...; 
    execSvc.submit(task1); 
    ... 
    execSvc.submit(taskN); 
    // important to request the exec service to shut down :) 
    execSvc.shutdown(); 

    new Thread(new Runnable() { 

     public void run() { 
      while (!execSvc.isTerminated()) { 
       try { 
        execSvc.awaitTermination(60, TimeUnit.SECONDS); 
       } catch (InterruptedException e) { 
        // ignore exception 
       } 
      } 
      System.out.println("ExecSvc.run: exec service has terminated!"); 
      // possibly submit a task using SwingUtilities.invokeLater() to update the UI 
     } 

    }).start(); 

Answer 5

Использование CountDownLatch

 

CountDownLatch latch = new CountDownLatch(totalNumberOfTasks); 
ExecutorService taskExecutor = Executors.newFixedThreadPool(4); 
while(...) { 
    taskExecutor.execute(new MyTask()); 
} 

try { 
    latch.await(); 
} catch (InterruptedException E) { 
    // handle 
} 

и в пределах вашей задачи (вложить в попытке /, наконец)

 latch.countDown(); 

Или на ExecutorService вы вызываете shutdown(), а затем awa itTermination()

 
ExecutorService taskExecutor = Executors.newFixedThreadPool(4); 
while(...) { 
    taskExecutor.execute(new MyTask()); 
} 
taskExecutor.shutdown(); 
try { 
    taskExecutor.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS); 
} catch (InterruptedException e) { 
    ... 
} 

Кроме того, есть взгляд на THIS ответ