摘要：起因業務中需要將一組數據分類后收集總和，原本可以使用，但是我們的數據源是類型的，而原生只提供了三種基礎類型的方法。于是就自己動手豐衣足食吧。。期望目標實踐依葫蘆先分析一下方法該方法接受類型的參數，返回類型的實例化對象。
起因
業務中需要將一組數據分類后收集總和，原本可以使用Collectors.summingInt()，但是我們的數據源是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類型的參數，返回CollectorImpl類型的實例化對象。CollectorImpl是Collector接口的唯一實現類
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的構造器參數，可知summingInt()方法是這樣的
arg[0]創建一個計算用的容器： () -> 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
千萬注意共享變量的使用
注意裝箱拆箱的開銷
基于數據量考慮使用并行流本身的成本
謹慎在并行流中使用事務
文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。
轉載請注明本文地址：http://m.specialneedsforspecialkids.com/yun/68088.html
