並列ソートと複数のフィールドを使用してリストをソート

Question

私はオブジェクトのリストを持っています。このリストは2つのパラメータに基づいてソートしています。 1.名字と 2.姓。

だから要件は、最初に姓に基づいてリストをソートし、姓に基づいて並べ替えます。

Comparator<Employee> groupComparator = Comparator.comparing(Employee::getFirstName) 
               .thenComparing(Employee::getLastName); 

をして、それが非常に細かい作業をされています

私は次のようにComparator.compairingとthenCompairingメソッドを使用して、これを実装しました。

私が望むのは、複数のスレッドを使用して並行して並べ替える並列処理/並べ替えの概念を使用することです。どのようにこれを達成するための任意のアイデア？

Answer 1

わずかな変更が、これは同様に動作するはずです：

List<Employee> sortedEmployees = employees.parallelStream() 
    .sorted(Comparator.comparing(Employee::getFirstName) 
        .thenComparing(Employee::getLastName)) 
    .collect(Collectors.toList()); 

をあなたが見る - にstream()を回すのと同じくらい簡単かもしれないパラレルへの溶液を回す - それは、ストリームに関する美しさの一つでありますparallelStream()！

しかし、いつものようにparallelStream使用して

：

は驚きのために準備する

• 対策の効果とこれは、データをソートします

Answer 2

Iは次のようにArrays.parallelSort法を用いて溶液を得た：

List<Employee> emps = getEmployees(); 
Comparator<Employee> groupComparator = Comparator.comparing(Employee::getFirstName) 
                .thenComparing(Employee::getLastName); 
Employee[] empArr = employees.toArray(new Employee[emps.size()]); 

//Parallel sorting 
Arrays.parallelSort(empArr, groupComparator); 

それが追加されたJava 8、ドキュメントによれば：

ソートアルゴリズムは平行で仕分けマージすると、配列がソートされてからマージされるサブ配列に分割されます。サブ配列の長さが最小の粒度に達すると、サブ配列は適切なArrays.sortメソッドを使用してソートされます。指定された配列の長さが最小精度よりも小さい場合は、適切なArrays.sortメソッドを使用してソートされます。このアルゴリズムでは、元の配列のサイズを超えないワーキングスペースが必要です。 ForkJoin共通プールは、任意の並列タスクを実行するために使用されます。

これはこれは、同様streamsを使用することによって達成することができ、ここで

Answer 3

私の問題を解決します。 streamsを使用すると、ソートする前にListを配列にコピーする必要はありません。

Stream<Employee> sorted = employees.stream() 
            .sorted(Comparator.comparing(Employee::getFirstName) 
            .thenComparing(Employee::getLastName)) 
            .parallel(); 

sorted.forEachOrdered(System.out::println);