Javaストリームによる並列ルーピング？

Question

私は2つのリストを持っています。 1つは、いくつかのゲームのためのグループの人々の各個人の成功した試みの数を示しています。

public class SuccessfulAttempts{ 
    String name; 
    int successCount; 
} 

List<SuccessfulAttempts> success; 

各個人の合計試行回数。

public class TotalAttempts{ 
    String name; 
    int totalCount; 
} 

List<TotalAttempts> total; 

そして、グループ内の各人の成功率を示したいと思います。

public class PercentageSuccess{ 
    String name; 
    float percentage; 
} 

List<PercentageSuccess> percentage; 

このような最初の2つのリストを作成したとします。

success.add(new SuccessfulAttempts(Alice, 4)); 
success.add(new SuccessfulAttempts(Bob, 7)); 

total.add(new TotalAttempts(Alice, 5)); 
total.add(new TotalAttempts(Bob, 10)); 

ここで、Java Streamsを使用する各人の成功率を計算したいと思います。だから私は実際にリストList<PercentageSuccess> percentageのためにこの種の結果が必要です。

new PercentageSuccess(Alice, 80); 
new PercentageSuccess(Bob, 70); 

そして、私は（私はループを使用して順次行う方法を知っている）並列でそれら（アリスの割合とボブの割合）を計算します。どのように私はJavaストリーム（または他の簡単な方法）でこれを達成することができますか？

Answer 1

あなたのリストの1つをマップに変換して、より簡単にアクセスできるようにすることをお勧めします。そうでなければ、O（n^2）の複雑さになるもう一方のリストでループしなければならない1つのリストの各値について。

List<SuccessfulAttempts> success = new ArrayList<>(); 
List<TotalAttempts> total = new ArrayList<>(); 

success.add(new SuccessfulAttempts("Alice", 4)); 
success.add(new SuccessfulAttempts("Bob", 7)); 

total.add(new TotalAttempts("Alice", 5)); 
total.add(new TotalAttempts("Bob", 10)); 

// First create a Map 
Map<String, Integer> attemptsMap = success.parallelStream() 
    .collect(Collectors.toMap(SuccessfulAttempts::getName, SuccessfulAttempts::getSuccessCount)); 

// Loop through the list of players and calculate percentage. 
List<PercentageSuccess> percentage = 
    total.parallelStream() 
     // Remove players who have not participated from List 'total'. ('attempt' refers to single element in List 'total'). 
     .filter(attempt -> attemptsMap.containsKey(attempt.getName())) 
     // Calculate percentage and create the required object 
     .map(attempt -> new PercentageSuccess(attempt.getName(), 
        ((attemptsMap.get(attempt.getName()) * 100)/attempt.getTotalCount()))) 
     // Collect it back to list 
     .collect(Collectors.toList()); 

percentage.forEach(System.out::println); 

Answer 2

配列が同じでsizeであり、正しく並べられている場合は、整数インデックスを使用して元のリスト要素にアクセスできます。

List<PercentageSuccess> result = IntStream.range(0, size).parallel().mapToObj(index -> /*get the elements and construct percentage progress for person with given index*/).collect(Collectors.toList()) 

これは、あなたが与えられたSuccessAttemptsとTotalAttemptsのための割合をconstruncts PercentageSuccessための方法やcustructorを作成しなければならないことを意味します。

PercentageSuccess(SuccessfulAttempts success, TotalAttempts total) { 
    this.name = success.name; 
    this.percentage = (float) success.successCount/(float) total.totalCount; 
} 

次に、あなたが平行であるサイズに0からの整数の流れを構築：

IntStream.range(0, size).parallel() 

これは実際にループの並列です。次に、各整数をindex '番目の人のPercentageSuccessにします（リストは同じサイズでシャッフルされていないことを保証する必要がありますが、私のコードは正しくありません）。

.mapToObj(index -> new PercentageSuccess(success.get(index), total.get(index)) 

、最終的に

.collect(Collectors.toList()) 

でリストにストリームを回すまた、このアプローチは、場合success又はtotalに最適ではないインデックスで要素にアクセスするためのO（n）のコストでのLinkedListまたは他のリストの実装であります。

Answer 3

private static List<PercentageAttempts> percentage(List<SuccessfulAttempts> success, List<TotalAttempts> total) { 

    Map<String, Integer> successMap = success.parallelStream() 
      .collect(Collectors.toMap(SuccessfulAttempts::getName, SuccessfulAttempts::getSuccessCount, (a, b) -> a + b)); 

    Map<String, Integer> totalMap = total.parallelStream() 
      .collect(Collectors.toMap(TotalAttempts::getName, TotalAttempts::getTotalCount)); 

    return successMap.entrySet().parallelStream().map(entry -> new PercentageAttempts(entry.getKey(), 
      entry.getValue() * 1.0f/totalMap.get(entry.getKey()) * 100)) 
      .collect(Collectors.toList()); 

}