摘要：起因業(yè)務中需要將一組數(shù)據(jù)分類后收集總和，原本可以使用，但是我們的數(shù)據(jù)源是類型的，而原生只提供了三種基礎類型的方法。于是就自己動手豐衣足食吧。。期望目標實踐依葫蘆先分析一下方法該方法接受類型的參數(shù)，返回類型的實例化對象。
起因
業(yè)務中需要將一組數(shù)據(jù)分類后收集總和，原本可以使用Collectors.summingInt()，但是我們的數(shù)據(jù)源是BigDecimal類型的，而Java8原生只提供了summingInt、summingLong、summingDouble三種基礎類型的方法。于是就自己動手豐衣足食吧。。
期望目標：
Map result = Arrays.stream(records).parallel().collect(Collectors.groupingBy(
Record::getType, CollectorsUtil.summingBigDecimal(Record::getAmount)));
實踐
1. 依葫蘆
先分析一下Collectors.summingInt()方法
public static Collector summingInt(ToIntFunction mapper) {
return new CollectorImpl<>(
() -> new int[1],
(a, t) -> { a[0] += mapper.applyAsInt(t); },
(a, b) -> { a[0] += b[0]; return a; },
a -> a[0], CH_NOID);
}
該方法接受ToIntFunction類型的參數(shù)，返回CollectorImpl類型的實例化對象。CollectorImpl是Collector接口的唯一實現(xiàn)類
CollectorImpl(Supplier supplier,
BiConsumer accumulator,
BinaryOperator combiner,
Function finisher,
Set characteristics) {
this.supplier = supplier;
this.accumulator = accumulator;
this.combiner = combiner;
this.finisher = finisher;
this.characteristics = characteristics;
}
分析CollectorImpl的構造器參數(shù)，可知summingInt()方法是這樣的
arg[0]創(chuàng)建一個計算用的容器： () -> new int[1]
arg[1]為計算邏輯： (a, t) -> { a[0] += mapper.applyAsInt(t); }
arg[2]為合并邏輯： (a, b) -> { a[0] += b[0]; return a; }
arg[3]為返回最終計算值： a -> a[0]
arg[4]為空Set(不知道干什么用。。)： Collections.emptySet()
2. 畫瓢
很自然的，BigDecimal的就是這樣了
public static Collector summingBigDecimal(Function mapper) {
return new CollectorImpl<>(() -> new BigDecimal[] { BigDecimal.ZERO }, (a, t) -> {
a[0] = a[0].add(mapper.apply(t));
}, (a, b) -> {
a[0] = a[0].add(b[0]);
return a;
}, a -> a[0], CH_NOID);
}
Java8并行流的一些tips
千萬注意共享變量的使用
注意裝箱拆箱的開銷
基于數(shù)據(jù)量考慮使用并行流本身的成本
謹慎在并行流中使用事務
文章版權歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請注明本文地址：http://www.ezyhdfw.cn/yun/68088.html
