java实现两个时间的累加_javaList相邻两个数据累加，可以⽤
stream的coll。。。
答案2.0
害，之前上⼀版答案，由于需求没有理解正确，所以惨败，这次再次理清了哈需求，这哪是List合并成⼀个LineDto
这⾥不得不说哈题主(甩锅开始)，⾮要说⽤ducing，⼈家reducing是⼲啥活的，⼈家是聚合。。。聚合操作⼀般是指 多 ->⼀，所以才有我认为是List合并成⼀个LineDto(甩锅完毕(ノへ￣、))
其实呢，这次看需求，其实就是每⼀个⽉的count做⼀个累加，不是最终合并成⼀个，⽽是每⼀个⽉的count都要做⼀次修正，因为数据是每个⽉单⽉的count数据，所以要修正为累计到该⽉的count
那既然这是修正操作，按照题主的思路也是正确的，就是要修正的⽉份count去加上上⼀个⽉的修正count即可。也就是这⾥⾯其实有⼀个中间变量LineDto，它总是表⽰上⼀个⽉的LineDto
需求整理清楚，再来看看在Stream的api中⽤什么合适。倒不是说⽤ducing不⾏，只是语义上不妥，就像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 -> {};
}java stream
/
/ 注意下⾯的merge，是把dto1中的值set到dto2中，所以dto1上⼀个⽉的
public static LineDto merge(LineDto dto1, LineDto dto2) {
dto2.Num1() + Num1());
dto2.Num2() + Num2());
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，我们进⾏合并操作，这⾥也不⼀定⾮要⽤ducing吧。。。咋的，是瞧不起咱们stream⾃带的reduce⽅法么？哈哈哈哈，开玩笑，⾃带明显⽐ducing少写⼏个字母嘛，程序员捡懒，我就按照duce来举例了哈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);
不过真⾮要⽤ducing也⾏，不过他们效果⼀样LineDto reduce = result.stream().ducing(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 + Num1();
this.num2 = this.num2 + Num2();
return this;
}
}
其实merge⽅法也没有多复杂，就是按照业务需求，把相应的字段进⾏合并即可
当然如果你为了LineDto的纯净简单性，不需要有这类业务代码耦合，那你可以写在其他地⽅，⽐如public class LineDtoHelper {
public static LineDto merge(LineDto dto1, LineDto dto2) {
dto1.Num1() + Num1());
dto1.Num2() + Num2());
return dto1;
}
}
那调⽤的时候就需要改为：LineDto lineDto = result.stream().reduce(new LineDto(), LineDtoHelper::merge);
其实也很简单吧，题主可以去玩玩试试~拜了个拜~(··)و✧

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。