Как дождаться завершения всех вызовов, прежде чем продолжить?

я следующий код хэшированного:Как дождаться завершения всех вызовов, прежде чем продолжить?

public class MyCallable implements Callable<Long> { 
    @Override 
    public Long call() throws Exception { 
     // Do stuff... 
    } 
} 

public class MyController { 
    private ExecutorService executor = Executos.newCachedTreadPool(); 

    public Long concurrentDoStuff() { 
     List<MyCallable> workers = makeWorkers(); 

     List<Long> allResults = new ArrayList<Long>(); 
     for(MyCallable worker : workers) { 
      Future<Long> workerResults = executor.submit(worker); 

      try { 
       allResults.add(workerResults.get()); 
      } catch(InterruptedException ie) { 
       // Handle... 
      } catch(ExecutionException ee) { 
       // Handle... 
      } 
     } 

     // Question: how do I pause here and wait for all workers to finish? 
    } 
}

После for -loop, я хочу, чтобы ждать, пока все рабочие, чтобы закончить, прежде чем продолжить дальше. Каков наилучший/безопасный/наиболее эффективный способ сделать это? Заранее спасибо!

источник

2013-05-10 IAmYourFaja

Вы хотите сначала представить все свои рабочие места, а затем ждать их результатов. В вашем коде вы ждете каждого результата, прежде чем окупить следующие задания, которые победят параллелизм. –

+1 @RalfH - вы должны хранить список фьючерсов и не разыгрывать их, пока не представите все задания. – Alex

Также вы должны скопировать/вставить код. У вас есть опечатки в приведенном выше! –

Вы должны закрыть Исполнителя с помощью shutDown, а затем дождаться, пока все задания будут обработаны с помощью awaitTermination.

источник

2013-05-10 13:21:01

Спасибо @ Ralf H (+1) - где бы я разместил эти 2 вызова? – IAmYourFaja

На самом деле вы можете использовать 'CompletionService'. –

Вы можете позвонить:

executor.shutdown(); 
executor.awaitTermination(Long.MAX_VALUE , TimeUnit.NANOSECONDS);

Это будет ждать (почти) на неопределенное время для выполнения задач, чтобы закончить.

источник

2013-05-10 13:22:20

Спасибо @ Duncan Jones (+1) - где бы я разместил эти 2 звонка? – IAmYourFaja

это будет ждать долгое время, но не так долго, как вы могли бы подумать. Сначала сумма будет конвертирована в наносекунды и переполнена. –

разместите эти вызовы после того, как вы представили все задания. –

Использовать CountDownLatch.

Инициализировать его с числом рабочих
Передайте ссылку на защелку в конструкторе рабочего
Когда работник будет сделано, позвоните countDown
Вызов await в главном потоке, и он будет блокировать пока рабочие не будут выполнены.

Это более универсальное решение, чем использование методов службы-исполнителя.

источник

2013-05-10 13:24:01 Alex

Это хорошая альтернатива. –

Спасибо @Alex (+1) - как этот подход справедлив иначе, чем стратегия 'shutdown' /' awaitTermination', рекомендованная другими? Это более эффективно? Безопаснее?Еще раз спасибо! – IAmYourFaja

не является ни более эффективным, ни безопасным, он просто вводит другой объект параллелизма. Как бы то ни было, Исполнитель может управлять статусом завершения с помощью shutdown и ждать завершения. Если вы все равно получаете() все свои фьючерсы, вы также убедитесь, что они завершены. Поэтому, если вы получите() свое последнее Будущее, вы знаете, что Executor прекращен. –

Существует удобный способ.

ExecutorService.invokeAll(List<Callable> callables);

Она возвращает List<Future> объектов, так что вы можете получить возврат объектов всех ваших индивидуальных call() методов.

Вы можете получить экземпляр ExecutorService по телефону Executors.new....()

источник

2013-05-11 01:53:34

Как дождаться завершения всех вызовов, прежде чем продолжить?

ответ

Смежные вопросы