Wie verarbeitet ein Java-Programm die Elemente einer Liste mit einer festgelegten Anzahl von Threads?

Mit einem festen Threadpool kannst du die Elemente einer Liste mit einer selbst festgelegten maximalen Threadanzahl verarbeiten.

Kleines vollständiges Beispiel

Das Beispiel verwendet Java 21 oder neuer. Der Executor wird durch den try-with-resources-Block automatisch geschlossen; dabei wartet das Programm auf die Fertigstellung der eingereichten Aufgaben.

import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ListParallel {
    public static void main(String[] args) {
        List<String> elemente = List.of(
                "Apfel", "Birne", "Kirsche", "Pflaume", "Orange"
        );

        int anzahlThreads = 3;

        try (ExecutorService executor =
                     Executors.newFixedThreadPool(anzahlThreads)) {

            for (String element : elemente) {
                executor.execute(() -> verarbeiten(element));
            }
        }

        System.out.println("Alle Aufgaben beendet.");
    }

    private static void verarbeiten(String element) {
        System.out.printf(
                "%s verarbeitet %s%n",
                Thread.currentThread().getName(),
                element.toUpperCase()
        );
    }
}

Was dabei passiert

Für jedes Listenelement wird eine Aufgabe eingereicht. Maximal drei Threads bearbeiten diese Aufgaben gleichzeitig; weitere Aufgaben warten in einer Warteschlange, bis ein Thread frei wird. Die Threadanzahl muss größer als null sein.

Wichtiger Unterschied: Du erzeugst nicht für jedes Element einen neuen Thread. Stattdessen verwenden die Aufgaben denselben festen Threadpool. Eine bestimmte Reihenfolge der Ausgaben solltest du bei paralleler Verarbeitung nicht voraussetzen.

Quellen:

• Executors: newFixedThreadPool, Oracle
• ExecutorService, Oracle