Warum verhindert „flatMap()' von Java 8, dass „findFirst()' einen Kurzschluss verursacht?

Verzögerte Ausführung in Java 8-Streams: Die Interaktion von FlatMap() und FindFirst() verstehen

In Java-Stream-Operationen ist flatMap() Der Operator wird verwendet, um jedes Element im Stream in einen neuen Stream umzuwandeln, der dann zu einem einzigen Stream zusammengefasst wird. Wenn es jedoch in Verbindung mit der Terminaloperation findFirst() verwendet wird, zeigt es ein interessantes Verhalten, das Fragen zur verzögerten Ausführung aufwirft.

Im bereitgestellten Codeausschnitt erstellen wir zwei Streams: einen, der nur filter() verwendet, und einen der andere verwendet sowohl flatMap() als auch filter(). Während der erste Stream seine Ausführung sofort beendet und das erste Element zurückgibt, verarbeitet der zweite Stream den gesamten Stream weiter, obwohl er ein passendes Element findet.

Warum die Diskrepanz?

Der Schlüssel zum Verständnis dieser Diskrepanz liegt in der Art und Weise, wie diese Operationen umgesetzt werden. findFirst() ist eine Kurzschlussoperation, was bedeutet, dass die Ausführung gestoppt werden kann, sobald ein passendes Element gefunden wird. Bei Verwendung nach flatMap() wird die filter()-Operation jedoch für jedes Element des von flatMap() erzeugten Zwischenstreams ausgeführt, unabhängig davon, ob bereits eine Übereinstimmung gefunden wurde.

Dieses Verhalten ist darauf zurückzuführen eine Einschränkung in der JDK-8-Stream-Implementierung. Wenn flatMap() verwendet wird, ist der resultierende Stream nicht vollständig verzögert. Stattdessen „zieht“ es eifrig Elemente aus dem Quellstream und wendet die flatMap()-Transformation auf jedes Element an. Das bedeutet, dass selbst nachdem findFirst() eine Übereinstimmung findet und einen Abbruch auslöst, die Elemente, die bereits in den Zwischenstream gezogen wurden, weiterhin vom Filter()-Operator verarbeitet werden.

Auflösung in Java 10 und Backports

Die Java-Entwickler haben dieses Problem erkannt und es in Java 10 behoben und auf Java 8 zurückportiert. In diesen aktualisierten Versionen hat flatMap() wurde vollständig verzögert gemacht, sodass Kurzschlussoperationen wie filter() die Stream-Ausführung ordnungsgemäß beenden können, sobald eine Übereinstimmung gefunden wird.

Implikationen und Überlegungen

Während dies Das Problem wurde in späteren Versionen von Java behoben. Es unterstreicht, wie wichtig es ist, die verzögerten Ausführungseigenschaften von Stream-Operationen zu verstehen, insbesondere wenn flatMap() in Kombination mit Kurzschlüssen verwendet wird Operatoren.

Wenn eine verzögerte Ausführung für Ihre Anwendung von entscheidender Bedeutung ist, wird empfohlen, Java 10 oder eine neuere Version zu verwenden, in der dieses Problem behoben wurde. Alternativ können Sie Kurzschlüsse manuell in Ihren flatMap()-Transformationen implementieren, um eine ordnungsgemäße Beendigung sicherzustellen.

Das obige ist der detaillierte Inhalt vonWarum verhindert „flatMap()' von Java 8, dass „findFirst()' einen Kurzschluss verursacht?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!