java实现两个时间的累加_java List 相邻两个数据累加,可以用stream的collectors.reducing实现么...

答案2.0

害，之前上一版答案，由于需求没有理解正确，所以惨败，这次再次理清了哈需求，这哪是List合并成一个LineDto

这里不得不说哈题主(甩锅开始)，非要说用collectors.reducing，人家reducing是干啥活的，人家是聚合。。。聚合操作一般是指 多 -> 一，所以才有我认为是List合并成一个LineDto(甩锅完毕(ノへ￣、))

其实呢，这次看需求，其实就是每一个月的count做一个累加，不是最终合并成一个，而是每一个月的count都要做一次修正，因为数据是每个月单月的count数据，所以要修正为累计到该月的count

那既然这是修正操作，按照题主的思路也是正确的，就是要修正的月份count去加上上一个月的修正count即可。也就是这里面其实有一个中间变量LineDto，它总是表示上一个月的LineDto

需求整理清楚，再来看看在Stream的api中用什么合适。倒不是说用collectors.reducing不行，只是语义上不妥，就像Stream的map操作明明是对象转换A -> B

但是有些人就是要使用成consumer的效果A -> A.set();return A;

所以结合需求，这是一个修正操作，是一个类似consumer的做法，结合Stream API，可以确定基本使用peek或者forEach。由于我们没有其他额外操作了，因此选择终结的方法forEach

直接贴出我的最终想法吧(代码里有些注释方便理解)

使用的时候很简单，直接上forEachresult.stream().forEach(createConsumer());

但是这个forEach输入条件consumer是咱们自己造的private static Consumer createConsumer() {

// 这里用的queue，你也可以用其他的容器，主要就是为了存储

// 上面提到的中间变量LineDto，表示上一个月的LineDto

BlockingQueue lastDtoQueue = new LinkedBlockingQueue<>(1);

// 做一个闭包，把lastDtoQueue冻结在下面的Consumer中

return dto -> createConsumer(lastDtoQueue, dto);

}

private static Consumer createConsumer(BlockingQueue lastDtoQueue, LineDto dto) {

// 插入成功，表示这个dto是第一个月的

if (lastDtoQueue.offer(dto)) return d -> {};

// 插入失败，表示lastDtoQueue已经有值，那就把这个值拿出来

LineDto lastDto = lastDtoQueue.poll();

merge(lastDto, dto);

// 因为之前poll已经删除了里面的dto，所以此时把这个月的dto放进去，

// 下次使用

lastDtoQueue.offer(dto);

return d -> {};

}

// 注意下面的merge，是把dto1中的值set到dto2中，所以dto1上一个月的

public static LineDto merge(LineDto dto1, LineDto dto2) {

dto2.setNum1(dto1.getNum1() + dto2.getNum1());

dto2.setNum2(dto1.getNum2() + dto2.getNum2());

return dto2;

}

如果你对于这种用闭包的方式理解起来比较麻烦，可以先尝试理解下面这个比较简单的处理

我们知道Stream的distinct()可以对流里的数据进行去重，但是这个去重基于的是equals方法，但是我们大多数的类的equals方法一般是不会去重写的，有时候我们去重的需求也很简单，只是说根据类里某个属性去重，这时候用这个小工具就可以处理public static Predicate distinctByKey(Function keyMapper){

Map map = new ConcurrentHashMap<>();

return p -> map.putIfAbsent(keyMapper.apply(p), Boolean.TRUE) == null;

}

这里就用到了闭包，使用时候也很简单students.stream().filter(distinctByKey(Student::getName))

借用filter方法实现了根据某个属性去重的效果

如果你能理解这个处理，那上面的造consumer也是一样的哈~

就这样叭~拜了个拜︿(￣︶￣)︿

答案1.0

y1s1哈，题主你这个稍微归纳总结一下嘛。。。不然非得让我们回答的人来理解你什么XXXCount的业务字段啊。。。万一看错了，导致最终提供的方法也就错了哦~

不过我自己理解下来，觉得你就是希望把一个List合并成一个LineDto，合并的要求是，某些数字字段(就是你那些XXXCount)分别相加合并

因为是某些字段，题主是XXXCount，那我就简化为num1，num2这样好看点的字段，如果明白我的思路，到时候题主自行转换一下就行了

那我把LineDto定义为：@Data

@AllArgsConstructor

@NoArgsConstructor

public class LineDto {

private int num1;

private int num2;

}

那提供一个List，我们进行合并操作，这里也不一定非要用collectors.reducing吧。。。咋的，是瞧不起咱们stream自带的reduce方法么？哈哈哈哈，开玩笑，自带明显比collectors.reducing少写几个字母嘛，程序员捡懒，我就按照stream.reduce来举例了哈List result = new ArrayList<>();

result.add(new LineDto(1, 20));

result.add(new LineDto(2, 30));

LineDto lineDto = result.stream().reduce(new LineDto(), LineDto::merge);

不过真非要用collectors.reducing也行，不过他们效果一样LineDto reduce = result.stream().collect(Collectors.reducing(new LineDto(), LineDto::merge));

这里reduce操作中第二个参数我用了LineDto::merge，这是一个额外方法，其实就是把LineDto合并操作抽取出来，我是写在了LineDto中，当然你也可以写在其他地方@Data

@AllArgsConstructor

@NoArgsConstructor

public class LineDto {

private int num1;

private int num2;

public LineDto merge(LineDto newLineDto) {

this.num1 = this.num1 + newLineDto.getNum1();

this.num2 = this.num2 + newLineDto.getNum2();

return this;

}

}

其实merge方法也没有多复杂，就是按照业务需求，把相应的字段进行合并即可

当然如果你为了LineDto的纯净简单性，不需要有这类业务代码耦合，那你可以写在其他地方，比如public class LineDtoHelper {

public static LineDto merge(LineDto dto1, LineDto dto2) {

dto1.setNum1(dto1.getNum1() + dto2.getNum1());

dto1.setNum2(dto1.getNum2() + dto2.getNum2());

return dto1;

}

}

那调用的时候就需要改为：LineDto lineDto = result.stream().reduce(new LineDto(), LineDtoHelper::merge);

其实也很简单吧，题主可以去玩玩试试~拜了个拜~(๑•̀ㅂ•́)و✧