Upload New File

src/main/java/es/uja/cursojee/simulaeventos/SimulaEventos2.java

+package es.uja.cursojee.simulaeventos;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.Future;
+import java.util.concurrent.TimeUnit;
+
+public class SimulaEventos2 {
+
+	public static void main(String[] args) throws InterruptedException {
+		// Variables
+		ExecutorService ejecutor;
+		List<Future<List<Evento>>> listaResultados;
+		Future<List<Evento>> resultado;
+
+		// Ejecución del hilo principal
+        System.out.println("Hilo(PRINCIPAL) comienza la ejecución");
+        
+        // Inicialización de las variables para la prueba
+        ejecutor = Executors.newCachedThreadPool();
+        listaResultados = new ArrayList();
+        
+        // Creamos las tareas de gestion
+        for(int i = 0; i < Constantes.NUM_GESTORES; i++) {
+        	int numEventos = Constantes.aleatorio.nextInt(Constantes.D100) + 1;
+        	TareaGestor2 gestor = new TareaGestor2("Gestor-"+i, numEventos);
+        	resultado = ejecutor.submit(gestor);
+        	listaResultados.add(resultado);
+        }
+        
+        TareaResultado tareaResultado = new TareaResultado("Resultado", listaResultados);
+        ejecutor.execute(tareaResultado);
+        
+        // Espera la finalización
+        System.out.println("Hilo(PRINCIPAL) espera a la finalización");
+        ejecutor.shutdown();
+        ejecutor.awaitTermination(Constantes.TIEMPO_ESPERA, TimeUnit.HOURS);
+		
+     // Finalización del hilo principal
+        System.out.println("Hilo(PRINCIPAL) ha fializado la ejecución");
+	}
+
+}