Pourquoi `flatMap()` de Java 8 empêche-t-il `findFirst()` de court-circuiter ?

Exécution retardée dans les flux Java 8 : compréhension de l'interaction FlatMap() et FindFirst()

Dans les opérations de flux Java, le flatMap() L'opérateur est utilisé pour transformer chaque élément du flux en un nouveau flux, qui est ensuite aplati en un seul flux. Cependant, lorsqu'il est utilisé conjointement avec l'opération de terminal findFirst(), il présente un comportement intéressant qui soulève des questions sur l'exécution paresseuse.

Dans l'extrait de code fourni, nous créons deux flux : un utilisant uniquement filter() et l'autre utilisant à la fois flatMap() et filter(). Alors que le premier flux termine immédiatement son exécution et renvoie le premier élément, le deuxième flux continue de traiter l'intégralité du flux malgré la recherche d'un élément correspondant.

Pourquoi cet écart ?

La clé pour comprendre cet écart réside dans la manière dont ces opérations sont mises en œuvre. findFirst() est une opération de court-circuit, ce qui signifie qu'elle peut arrêter l'exécution une fois qu'un élément correspondant est trouvé. Cependant, lorsqu'elle est utilisée après flatMap(), l'opération filter() est exécutée sur chaque élément du flux intermédiaire produit par flatMap(), qu'une correspondance ait déjà été trouvée ou non.

Ce comportement est dû à une limitation dans l'implémentation du flux JDK-8. Lorsque flatMap() est utilisé, le flux résultant n’est pas complètement paresseux. Au lieu de cela, il « extrait » avec impatience les éléments du flux source et applique la transformation flatMap() à chaque élément. Cela signifie que même après que findFirst() ait trouvé une correspondance et déclenché l'annulation, les éléments qui ont déjà été extraits dans le flux intermédiaire continuent d'être traités par l'opérateur filter().

Résolution en Java 10. et rétroportages

Reconnaissant ce problème, les développeurs Java l'ont corrigé dans Java 10 et l'ont rétroporté vers Java 8. Dans ces versions mises à jour, flatMap() a été rendu entièrement paresseux, permettant aux opérations de court-circuit telles que filter() de terminer correctement l'exécution du flux une fois qu'une correspondance est trouvée.

Implications et considérations

Bien que ce problème ait été résolu dans les versions ultérieures de Java, il souligne l'importance de comprendre les caractéristiques d'exécution paresseuse des opérations de flux, en particulier lors de l'utilisation de flatMap() en combinaison avec un court-circuit. opérateurs.

Si l'exécution paresseuse est cruciale pour votre application, il est recommandé d'utiliser Java 10 ou une version ultérieure où ce problème a été résolu. Alternativement, vous pouvez implémenter manuellement un court-circuit dans vos transformations flatMap() pour garantir une terminaison correcte.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!