Java Streams와의 병렬 루핑?

Question

두 개의 목록이 있습니다. 하나는 어떤 게임에서 한 그룹의 각 개인에 대한 성공적인 시도 횟수를 보여줍니다.

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; 

다음과 같이 처음 두 목록을 채우는 것으로 가정합니다.

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 Streams (또는 다른 간단한 방법)로 어떻게 이것을 할 수 있습니까 ??

Answer 1

귀하의 목록 중 하나를 쉽게지도에 액세스 할 수 있도록지도로 변환하는 것이 좋습니다. 다른 목록에서 반복해야하는 목록의 각 값은 O (n^2) 개의 복잡도가됩니다.

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

배열의 배열이 동일하고 올바르게 정렬 된 경우 정수 인덱스를 사용하여 원본 목록 요소에 액세스 할 수 있습니다.

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를 만드는 것을 의미합니다.

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

이 실제로 루프 평행 :

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

는 그러면 평행 크기 0의 정수의 스트림을 구성. 그런 다음 각 정수를 index '번째 사람의 PercentageSuccess로 바꿉니다 (목록은 크기가 같고 섞이지 않아야하며 다른 코드는 올바르지 않은지 확인하십시오).

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

최종적 또한

.collect(Collectors.toList()) 

으로 목록에 트림을 설정이 접근법 LinkedList의 인덱스에 의해 소자를 액세스 O (n)을 선정 다른리스트의 구현 사례 success 또는 total에서 최적 아니다 .

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()); 

}