package com.stuelken.java.b4.parallel.c12.concurrentinvokeall;

import java.util.concurrent.*;
import java.util.*;

/**
 * @author t2m
 */
public class InvokeAllDemo {

	// Startzeitpunkt
	public static long start;

	// Hilfsmethode für Differenz der Zeit.
	public static String getDifferenzZeit() {
		return (System.currentTimeMillis() - start) + "ms";
	}

	public static void main(String[] args) throws InterruptedException, ExecutionException {

		// Sicherstellen, dass wir immer 4 Threads auf einmal laufen lassen können.
		// Diese Limitierung ist gewollt.
		ExecutorService executor = Executors.newFixedThreadPool(4);

		// Für die Erfassung von Referenzen auf Callables eine Collection nutzen.
		List<Callable<String>> taskList = new ArrayList<>();

		// Ein paar Callables erzeugen.
		for (int i = 1; i <= 12; i++) {

			final int id = i; // Nur finale Werte können an Lambdas durchgereicht werden.

			taskList.add(() -> {
				System.out.printf(
				 "Task #%02d gestartet auf Thread %s | %s%n", //
				 id, Thread.currentThread().getName(), //
				 getDifferenzZeit() //
				);
				Thread.sleep(5000);
				System.out.printf("Task #%02d beendet auf Thread %s | %s%n", //
				 id, Thread.currentThread().getName(), //
				 getDifferenzZeit() //
				);
				return "Ergebnis von Task #" + id;
			});
		}

		System.out.println("Alle Tasks werden parallel eingereicht…");
		start = System.currentTimeMillis();

		List<Future<String>> futures = executor.invokeAll(taskList);

		System.out.println("Alle Tasks ausgeführt, warte auf Ergebnisse…");
		for (Future<String> future : futures) {
			String result = future.get(); // blockierend
			System.out.println("result: " + result);
		}

		executor.shutdown();
		System.out.println("Dauer: " + getDifferenzZeit());
	}

}
// @formatter:off
/*
Alle Tasks werden parallel eingereicht�
Task #01 gestartet auf Thread pool-1-thread-1 | 11ms
Task #04 gestartet auf Thread pool-1-thread-4 | 11ms
Task #02 gestartet auf Thread pool-1-thread-2 | 11ms
Task #03 gestartet auf Thread pool-1-thread-3 | 11ms
Task #01 beendet auf Thread pool-1-thread-1 | 5081ms
Task #04 beendet auf Thread pool-1-thread-4 | 5081ms
Task #02 beendet auf Thread pool-1-thread-2 | 5081ms
Task #05 gestartet auf Thread pool-1-thread-2 | 5086ms
Task #06 gestartet auf Thread pool-1-thread-4 | 5086ms
Task #07 gestartet auf Thread pool-1-thread-1 | 5088ms
Task #03 beendet auf Thread pool-1-thread-3 | 5089ms
Task #08 gestartet auf Thread pool-1-thread-3 | 5090ms
Task #05 beendet auf Thread pool-1-thread-2 | 10088ms
Task #09 gestartet auf Thread pool-1-thread-2 | 10089ms
Task #08 beendet auf Thread pool-1-thread-3 | 10093ms
Task #06 beendet auf Thread pool-1-thread-4 | 10093ms
Task #07 beendet auf Thread pool-1-thread-1 | 10093ms
Task #11 gestartet auf Thread pool-1-thread-4 | 10096ms
Task #10 gestartet auf Thread pool-1-thread-3 | 10095ms
Task #12 gestartet auf Thread pool-1-thread-1 | 10097ms
Task #09 beendet auf Thread pool-1-thread-2 | 15093ms
Task #12 beendet auf Thread pool-1-thread-1 | 15105ms
Task #11 beendet auf Thread pool-1-thread-4 | 15106ms
Task #10 beendet auf Thread pool-1-thread-3 | 15105ms
Alle Tasks ausgef�hrt, warte auf Ergebnisse�
result: Ergebnis von Task #1
result: Ergebnis von Task #2
result: Ergebnis von Task #3
result: Ergebnis von Task #4
result: Ergebnis von Task #5
result: Ergebnis von Task #6
result: Ergebnis von Task #7
result: Ergebnis von Task #8
result: Ergebnis von Task #9
result: Ergebnis von Task #10
result: Ergebnis von Task #11
result: Ergebnis von Task #12
Dauer: 15111ms

*/