Estoy creando un bechmark básico en Java, el cual lee el numero de núcleos que tiene la CPU de la maquina en donde el programa se ejecuta. Se crean tantos hilos como tenga núcleos el procesador de la maquina.
El caso es que desde el hilo principal del programa, quiero ejecutar un código aparte, pero no se como hacer para que esta parte espere a que todos los hilos secundarios terminen de ejecutarse para que esta ultima parte se ejecute.
Esta es la clase principal, o el hilo principal.
public class Main{
public Main() {
long numero = 100000;
ArrayList<Bench> threads = new ArrayList<>();
for (int i = 0; i < Bench.getCores(); i++) {
threads.add(new Bench(numero));
threads.get(i).start();
}
this.calcularTiempos(threads);
}
/**
* @param args the command line arguments
*/
public static void main(String[] args) {
Main m = new Main();
}
private void calcularTiempos(ArrayList<Bench> threads) {
float time = 0;
for(int i = 0 ; i < threads.size(); i++){
System.out.println("Tiempo del hilo " + i + ": " + threads.get(i).getTime());
time += threads.get(i).getTime();
}
time = time/Bench.getCores();
System.out.println("Tiempo promedio: " + time);
}
}
El resto de hilos hacen lo mismo que esta en el metodo run:
public class Bench implements Runnable{
private Thread hilo;
private final long numero;
private float time;
public Bench(long numero) {
this.numero = numero;
}
public BigInteger foo(long n) {
/****/
}
@Override
public void run() {
float inicio = System.currentTimeMillis();
//while(true){
for(int i = 0 ; i < numero; i++){
this.foo(i);
}
//}
this.time = System.currentTimeMillis() - inicio;
}
public void start(){
hilo = new Thread(this, String.valueOf(numero));
hilo.start();
}
public void stop(){
if(hilo != null){
hilo.stop();
}
}
public static int getCores(){
return Runtime.getRuntime().availableProcessors();
}
public float getTime() {
return time;
}
public void setTime(float time) {
this.time = time;
}
}
Necesito que la función calcularTiempos
se ejecute cuando los n
hilos creados hayan terminado en su ejecución.
Gracias.