Este corte de código, muestra como crear y disparar un grupo de hilos, en paralelo.
Usa la conveniente sintaxis de "String...", para recibir de 0 a N parametros, implementa, mediante clases anonimas los objetos Runnable y utiliza el método join, para bloquear el hilo actual, hasta que el hilo invocado termine su ejecución, así se asegura que todos los hilos terminen su ejecución antes de salir del método runInParallel.
public static void main(String[] args) {
runInParallelExample();
}
public static void runInParallelExample () {
runInParallel(true,
new Runnable () {
@Override
public void run() {
System.out.println("Happy");
}
},
new Runnable () {
@Override
public void run() {
System.out.println("New");
}
},
new Runnable () {
@Override
public void run() {
System.out.println("Year");
}
},
new Runnable () {
@Override
public void run() {
System.out.println("All");
}
}
);
}
/**
* Ejecuta todos los hilos en paralelo
*
* @param wait
* true si desea que el metodo espere hasta que se ejecuten todos los hilos
* @param runnables
* Conjunto de objetos runnables
*/
public static void runInParallel(boolean wait, Runnable... runnables) {
List threads = null;
Thread thread = null;
try {
// Creo los objetos
threads = new ArrayList();
// Creo la lista con los hilos y los ejecuto
for (Runnable r : runnables) {
thread = new Thread(r);
threads.add(thread);
thread.start();
}
// If desea que el metodo espere
if (wait) {
for (Thread t : threads) {
t.join();
}
}
} catch (Exception e) {
/** Catch or throws the error */
}
} // runInParallel.
Usa la conveniente sintaxis de "String...", para recibir de 0 a N parametros, implementa, mediante clases anonimas los objetos Runnable y utiliza el método join, para bloquear el hilo actual, hasta que el hilo invocado termine su ejecución, así se asegura que todos los hilos terminen su ejecución antes de salir del método runInParallel.
public static void main(String[] args) {
runInParallelExample();
}
public static void runInParallelExample () {
runInParallel(true,
new Runnable () {
@Override
public void run() {
System.out.println("Happy");
}
},
new Runnable () {
@Override
public void run() {
System.out.println("New");
}
},
new Runnable () {
@Override
public void run() {
System.out.println("Year");
}
},
new Runnable () {
@Override
public void run() {
System.out.println("All");
}
}
);
}
/**
* Ejecuta todos los hilos en paralelo
*
* @param wait
* true si desea que el metodo espere hasta que se ejecuten todos los hilos
* @param runnables
* Conjunto de objetos runnables
*/
public static void runInParallel(boolean wait, Runnable... runnables) {
List
Thread thread = null;
try {
// Creo los objetos
threads = new ArrayList
// Creo la lista con los hilos y los ejecuto
for (Runnable r : runnables) {
thread = new Thread(r);
threads.add(thread);
thread.start();
}
// If desea que el metodo espere
if (wait) {
for (Thread t : threads) {
t.join();
}
}
} catch (Exception e) {
/** Catch or throws the error */
}
} // runInParallel.
Comentarios