Эффективный способ дождаться завершения Runnable задач в ExecutorService

Question

У меня есть n-число Runnable задач (не вызываемых), которые я выполняю с помощью ExecutorService.

Я хочу дождаться завершения всех задач.

Я не могу использовать invokeAll - потому что он работает для сбора Callables.

Я не могу использовать shutdown()+awaitTermination, потому что awaittermination требует предоставить тайм-аут, но мои задачи могут занять несколько часов.

можно использовать:

ExecutorService.shutdown();    
while (!ExecutorService.isTerminated()) {} 

Но этот цикл будет всегда срабатывает.

Что предлагается в таком сценарии?

Answer 1

Вы можете использовать ExecutorService.awaitTermination(Long.MAX_VALUE, TimeUnit.HOURS);

Answer 2

ExecutorService.awaitTermination() возвращает boolean, который указывает, если исполнитель прекращается или не истечет время ожидания. Вы можете назвать это конечно в цикле:

ExecutorService executor = ...; 

executor.shutdown(); 
while (!executor.awaitTermination(24L, TimeUnit.HOURS)) { 
    System.out.println("Still waiting for the executor to finish"); 
} 

System.out.println("Executor finished"); 

Answer 3

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

Semaphore s =new Semaphore(0); 
    while(..){ 
    if (isLastTask){ 
     taskExecutor.execute(new Task(s)); 
    } else 
     taskExecutor.execute(new Task()); 
    } 
    s.acquire(1); 

class Task implement implements Runnable { 
    Semaphore s; 

    public Task(){ 
    this(null); 
    } 

    public Task (Semaphore s){ 
    this.s = s; 
    } 

    public void run(){ 
     ...... 
     if (s != null) 
      s.release(); 
    } 
}