java 8 parallelStream() avec triés()

JDK 8 EA est maintenant, et je suis juste essayer d'obtenir utilisé pour le lambda et le nouveau Flux de données de l'API. J'ai essayé de trier une liste avec courant parallèle, mais le résultat est toujours faux:

import java.util.ArrayList;
import java.util.List;

public class Test
{
    public static void main(String[] args)
    {
        List<String> list = new ArrayList<>();
        list.add("C");
        list.add("H");
        list.add("A");
        list.add("A");
        list.add("B");
        list.add("F");
        list.add("");

        list.parallelStream() //in parallel, not just concurrently!
            .filter(s -> !s.isEmpty()) //remove empty strings
            .distinct() //remove duplicates
            .sorted() //sort them
            .forEach(s -> System.out.println(s)); //print each item
    }
}

De SORTIE:

C
F
B
H
A

Remarque que chaque fois que le résultat est différent. Mes questions: est-ce un bug? ou n'est-il pas possible de trier une liste en parallèle? si oui, alors pourquoi la JavaDoc n'est pas l'état qui? Dernière question, est-il une autre opération dont le résultat serait différent en fonction du type de flux?

  • Il serait probablement préférable de supprimer les doublons après le tri.
InformationsquelleAutor Eng.Fouad | 2013-10-22
  1. 52

    Vous devez utiliser forEachOrdered, pas forEach.

    Que par la forEach doc:

    Parallèle stream, cette opération n'est pas garantie à l'égard de la rencontre de l'ordre du cours d'eau, afin d'éviter de sacrifier au profit de parallélisme. Pour tout élément donné, l'action peut être exécutée à n'importe quel moment et dans quel thread de la bibliothèque choisit. Si l'action accède à un état partagé, il est responsable de fournir la synchronisation requise.

    • +1 Splendide! C'est ce que je cherchais.
    • Ma conjecture est que, en interne, c'est la création d'un "triés" liste, chaque thread s'ajoute à cette liste, puis continue à la prochaine étape dans le flux (le forEach) de sorte qu'il exécute l'ordre, FWIW.
    InformationsquelleAutor Louis Wasserman
  2. 6

    En outre, vous pouvez lire plus au sujet du parallélisme et de la forEachOrdered avec un très bel exemple de ici. En résumé, l'utilisation forEachOrdered dans un courant parallèle pourrait résulter de perdre les avantages de parallélisme.

    Ici l'exemple de la même ressource:

    Integer[] intArray = {1, 2, 3, 4, 5, 6, 7, 8 };
List<Integer> listOfIntegers =
    new ArrayList<>(Arrays.asList(intArray));

System.out.println("listOfIntegers:");
listOfIntegers
    .stream()
    .forEach(e -> System.out.print(e + " "));
System.out.println("");

System.out.println("listOfIntegers sorted in reverse order:");
Comparator<Integer> normal = Integer::compare;
Comparator<Integer> reversed = normal.reversed(); 
Collections.sort(listOfIntegers, reversed);  
listOfIntegers
    .stream()
    .forEach(e -> System.out.print(e + " "));
System.out.println("");

System.out.println("Parallel stream");
listOfIntegers
    .parallelStream()
    .forEach(e -> System.out.print(e + " "));
System.out.println("");

System.out.println("Another parallel stream:");
listOfIntegers
    .parallelStream()
    .forEach(e -> System.out.print(e + " "));
System.out.println("");

System.out.println("With forEachOrdered:");
listOfIntegers
    .parallelStream()
    .forEachOrdered(e -> System.out.print(e + " "));
System.out.println("");

    Et la sortie est

    listOfIntegers:
1 2 3 4 5 6 7 8
listOfIntegers sorted in reverse order:
8 7 6 5 4 3 2 1
Parallel stream:
3 4 1 6 2 5 7 8
Another parallel stream:
6 3 1 5 7 8 4 2
With forEachOrdered:
8 7 6 5 4 3 2 1

    La cinquième pipeline utilise la méthode forEachOrdered, qui traite de la
    les éléments du flux dans l'ordre spécifié par sa source,
    indépendamment de savoir si vous avez exécuté le flux en série ou en parallèle.
    Notez que vous risquez de perdre les avantages de parallélisme si vous utilisez
    des opérations comme forEachOrdered avec flux parallèles

    .

    • C'est un peu mince. Veuillez élargir votre réponse à la question en la modifiant.
    InformationsquelleAutor cemal