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

Question

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

Answer 1

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

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

Answer 2

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

Answer 3

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

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

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

и в пределах вашей задачи (заключите в try / finally)

latch.countDown();

Или в ExecutorService вы вызываете shutdown (), а затемawaitTermination ()

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

Также взгляните на ЭТО ответ

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

isTerminated() сделает

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