Java 8中的一組數據的並行計算？

Question

我有一組數據是這樣的：

Set<CustomObject> testSet = [{id: a1, qty: 3}, 
          {id: a2, qty: 9}, 
          {id: a3, qty: 5}, 
          {id: a4, qty: 8}, 
          {id: a5, qty: 12}, 
          ... 
          {id: a200, qty: 7}]; 

ID被分成3組，可以使用該方法中找到：以上

//The getGroup method is implemented in the class CustomObject. 
//I am using hazelcast map to store few id's that are inclusive, and 
//one of the id that is in the request of the api is the current id. 
public String getGroup(String id){ 
    HazelcastInstance hazelcastInstance = Hazelcast.newHazelcastInstance(); 
    if(id.equals(this.id)){ 
     return "currentId"; 
    }else if(id.equals(hazelcastInstance.getMap("idMap").get(id))){ 
     return "inclusive"; 
    } else { 
     return "exclusive"; 
    } 
} 

的測試集是具有巨大的數據，我要使用Java根據上面的分組方法執行Set中每個對象的數量總和。

我嘗試使用流，但不允許我在Java 8 Streaming的groupingBy方法中使用getGroup方法。

請指導我如何有效地總結基於組並行處理的數量值。

Answer 1

這裏是代碼將給包容和獨家數量的總和分組。

Map<Object, Integer> resultMap = 
       testSet.stream().parallel() 
       .collect(Collectors.groupingBy(item -> { 
            if(item.getId().equals(hazelcastInstance.getMap("idMap").get(id)) 
             return "inclusive"; 
            else 
             return "exclusive"; 
            }, 
            Collectors.summingInt(CustomObject::getQty))); 

此外，爲了獲得更好的性能，當使用並行流並測量它時，使用ArrayList而不是HashSet。