Java: Multithreading -Wait/notifyToda la pregunta

Question

Tengo una clase que genera un montón de hilos y tiene que esperar hasta que se completen todos los hilos generados. (Necesito calcular el tiempo para completar todos los hilos).

MainClass genera todos los hilos y luego comprueba si todos los hilos se completan antes de que pueda llamarse a sí mismo completado.

Funcionará esta lógica. Si es así, ¿hay una mejor manera de hacer esto? Si no, me gustaría entender mejor este escenario.

class MainClass{ 
    private boolean isCompleted; 
    ... 
    for(task : tasks){ 
     threadpool.execute(task); 
    } 

    for(task : tasks){ 
     if(!task.isCompleted()){ 
      task.wait() 
     } 
    } 

    isCompleted = true; 
} 


class Task{ 
    public void run(){ 
     .... 
     .... 
     synchronized(this){ 
      task.completed = true; 
      notifyAll(); 
     } 
    } 
} 

Answer 1

notifyAll() es relativamente lento. Una mejor manera es utilizar CountDownLatch:

import java.util.concurrent.CountDownLatch; 

int n = 10; 
CountDownLatch doneSignal = new CountDownLatch(n); 
// ... start threads ... 
doneSignal.await(); 

// and within each thread: 
doWork(); 
doneSignal.countDown(); 

Answer 2

No hay necesidad de esperar/notificará en este caso. Puede simplemente recorrer los hilos y llamar al join(). Si el hilo ya está terminado, el hilo de MainClass simplemente esperará al siguiente.

Es posible que desee echar un vistazo a las utilidades de nivel superior en el paquete java.util.concurrent también.

Answer 3

Todo esto se puede hacer mediante java.util.concurrent.ExecutorService.

class MainClass { 
    ... 
    ExecutorService executor = Executors.newCachedThreadPool(); 
    List<Callable> tasks = ...; // prepare your tasks 

    // this invokes all tasks in parallel and waits until all are done 
    executor.invokeAll(tasks); 
    ... 
} 

Eso es todo.