Étant donné un flux de valeurs primitives ou d'objet, la tâche se pose de le transformer en un flux de paires, où chaque paire comprend deux éléments successifs du flux d'origine. Par exemple, étant donné le flux {0, 1, 2, 3, 4}, le résultat souhaité serait :
{ new Pair(0, 1), new Pair(1, 2), new Pair(2, 3), new Pair(3, 4) }
Analyse
Les flux Java 8 La bibliothèque excelle dans la division des flux en portions plus petites pour un traitement parallèle. Cependant, il offre une prise en charge limitée des étapes de pipeline avec état, ce qui rend difficile l'accès aux éléments de flux adjacents et l'obtention de l'index de l'élément actuel.
Solution
Pour surmonter ces problèmes limitations, nous pouvons tirer parti d’une approche indexée dans laquelle nous pilotons le flux à l’aide d’index. Cela nécessite que les valeurs soient stockées dans une structure de données à accès aléatoire comme une ArrayList, à partir de laquelle les éléments peuvent être facilement récupérés. Avec les valeurs d'une ArrayList, nous pouvons construire les paires comme suit :
IntStream.range(1, arrayList.size()) .mapToObj(i -> new Pair(arrayList.get(i-1), arrayList.get(i))) .forEach(System.out::println);
Notez que cette approche a la contrainte d'exiger que l'entrée soit un flux fini. Cependant, le pipeline peut être exécuté en parallèle.
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!