Java 24: Stream Gatherers - Die Revolution der Stream-Verarbeitung

Eine lang erwartete Ergänzung

Seit der Einführung der Stream API in Java 8 mussten Entwickler mit einem fixen Set von intermediären Operationen arbeiten. Während terminale Operationen durch collect(Collector) erweiterbar waren, fehlte eine entsprechende Möglichkeit für Zwischenoperationen. Mit JDK 24 ändert sich das grundlegend durch die Einführung von Stream Gatherers.

Was sind Stream Gatherers?

Stream Gatherers sind das Pendant zu Collectors für intermediäre Operationen. Sie werden über die neue Methode Stream.gather(Gatherer) eingebunden und ermöglichen es, Streams flexibel zu transformieren. Ein Gatherer kann dabei:

• Eins-zu-eins, eins-zu-viele, viele-zu-eins oder viele-zu-viele Transformationen durchführen
• Zustand zwischen Elementverarbeitungen speichern
• Die Verarbeitung vorzeitig beenden (Short-Circuit)
• Optional parallel ausgeführt werden

Mitgelieferte Implementierungen

Das JDK liefert bereits einige nützliche Gatherers in der Klasse java.util.stream.Gatherers:

Implementierung eigener Gatherers

Ein Gatherer wird durch vier Funktionen definiert:

1. Initializer: Erstellt ein Objekt für den privaten Zustand
2. Integrator: Verarbeitet neue Elemente und emittiert Ergebnisse
3. Combiner (optional): Ermöglicht parallele Verarbeitung
4. Finisher: Wird am Ende aufgerufen und kann finale Elemente emittieren

Praktisches Beispiel

var result = Stream.of("foo", "bar", "baz", "quux")
                   .gather(distinctByLength())
                   .toList();