Stream几种常见用法示例

zhou66

（1）收集List对象的某个字段属性形成List（可加distinct去重）

1. //List<YwdjpcrjcjlHVO> rjcList
   
2. List<String> cbpcList= rjcList.stream().map(YwdjpcrjcjlHVO::getCbpc).distinct().collect(Collectors.toList());

复制代码

(2) 将List 对象集合，按某个属性或属性组合进行分组汇总

1. //List<YwdjpcrjcjlHVO> rjcList
   
2. 
   
3.                 Map<String,List<YwdjpcrjcjlHVO>> rjcjlMap=rjcList.stream().collect(Collectors.groupingBy(e -> e.getYzccode()+e.getScx()+e.getZzlxcode()));
   

复制代码

(3) 将List<String>对象或数组 进行拼接

1. field = bomsxzList.stream().map(e -> e).collect(Collectors.joining(","));

复制代码

(4) 将list列表对象，转成按某个计算值为KEY的MAP

1.   List<DyfbzVO> dyfbzList = (List<DyfbzVO>) getBaseDAO().executeQuery(sql.toString(), new BeanListProcessor(DyfbzVO.class));
   
2.                 Map<String, DyfbzVO> cbjzlxMap = <b>dyfbzList.stream()
   
3.                                 .collect(Collectors.toMap(e -> e.getType()+e.getVariety(), e -> e, (v1, v2) -> v2));</b>
   

复制代码

(5) 将集合对象循环用法：

1. DyfglBVOArray<b>.stream().forEach(bodyEntity -></b> {
   
2.       //statements
   
3. });

复制代码

(6) List对象筛选过滤

1.   List<YwdjfpswzxDetailHVO> tzList = <b>allList.stream().filter(e -> "2".equals(e.getZxzt()))</b>
   
2.                                 .collect(Collectors.toList());

复制代码

(7) 并行流执行

1. //pool : ForkJoinPool

复制代码

(8) 将list 集合分组执行

1. int no = swfytzVOList.size() / maxSize + 1;
   
2.                         for (int i = 0; i < no; i++) {
   
3.       List<AggSwfytz> newList =<b> swfytzVOList.stream().skip(i * maxSize).limit(maxSize)</b>
   
4.                .collect(Collectors.toList());
   
5.       AggSwfytz[] vos = service.saveAggSwfytz(newList.toArray(new AggSwfytz[0]));
   
6.      saveDataList.addAll(Arrays.asList(vos));
   
7.                         }

复制代码

zhou66

补充转MAP的两种用法：

1.                 Map<String, UFDouble> swbomMaxDays = swbomMaxDaysList.stream()
   
2.                                 .collect(Collectors.toMap(e -> e.getZzlb(), e -> e.getDays(), (v1, v2) -> v2));
   
3. 
   
4. //2
   
5.                 Map<String, YwdjcbhsfpxsBVO> fpxs = fpxsList.stream()
   
6.                                 .collect(Collectors.toMap(YwdjcbhsfpxsBVO::getZzlx, e -> e, (v1, v2) -> v2));

复制代码

zhou66

(9) MapToDouble 进行汇总

1.         private Double getDenominator(String cbdy, List<PcrclHVO> rclListFilter, Map<String, JcsjswbomHVO> swbom,
   
2.                         Map<String, UFDouble> swbomMaxDays, List<String> rclsxzList, Map<String, YwdjcbhsfpxsBVO> fpxs,
   
3.                         Map<String, UFDouble> numeratorMap) {
   
4.                
   
5.                 return rclListFilter.stream().mapToDouble(
   
6.                                 e -> getNumerator(cbdy, e, getSwbom(e, swbom, swbomMaxDays, rclsxzList), getFpxs(e, fpxs), numeratorMap)
   
7.                                                 .doubleValue())
   
8.                                 .sum();
   
9.         }

复制代码

zhou66

1.                         UFDouble nmoney = new UFDouble(entry.getValue().stream().mapToDouble(e -> e.getFtje().doubleValue()).sum())
   
2.                                         .multiply(multiplier);

复制代码

Marco-1988

感谢分享！！

chyp1123

先下来学习学习