1
lu5je0 260 天前
reduce
|
3
Curiosity777 OP @lu5je0 reduce 最后结果就是一个了
|
4
palytoxin 260 天前
reduce
|
5
ZGame 260 天前
楼上正解,Op 可以去了解下 c# linq 的操作符,或者 js 相关的。 然后用 gpt 翻译 java 有惊喜= =
|
6
NelsonZhao 260 天前
没必要强行用 stream ,用 for 循环自己处理呗
|
7
Habyss 260 天前
创建一个临时值存就可以了呀
```java // 临时累加值 AtomicReference<Double> cumulative = new AtomicReference<>(0.0); // 使用流进行累计值计算 return data.stream() // 排序 .sorted(Comparator.comparingInt(DataItem::getId)) // 看你情况是源对象处理还是返回新的对象 .peek(item -> { // 累加 cumulative.updateAndGet(v -> v + item.getCurrentValue()); // 设置当前累计值 item.setCumulativeValue(cumulative.get()); }) .collect(Collectors.toList()); ``` |
8
liumao 260 天前
巧了,上个月才做了这个需求,没必要非要用流,容易绕进去。
|
9
cpstar 260 天前
看了 7 楼,徒增编译器压力和代码阅读压力,…(⊙_⊙;)…
|
10
piecezzz 260 天前
static class Test{
public Test(Integer id,float cur,float total){ this.id = id; this.curVal = cur; this.totalVal = total; } public Integer id; public float curVal; public float totalVal; } public static void main(String[] args) { Test one = new Test(10,7.66f,928.09f); Test two = new Test(9,6.56f,920.43f); Test three = new Test(8,4.79f,913.87f); Test four = new Test(7,6.23f,909.08f); Stream.of(one,two,three,four).sorted(Comparator.comparing(t -> t.id)) .reduce((prev, cur) -> { cur.totalVal += prev.curVal; return cur; }); System.out.println(one.totalVal); } |
11
ocean1477 260 天前
mysql 的情况下 sql 也可以啊
select id, cur_val + lag(acc_val, 1, 0) over (order by id) as sum_val from test order by id desc; java8 的话也行 ```java MyObj obj1 = new MyObj(10, 7.66, 928.09, 0.0); MyObj obj2 = new MyObj(9, 6.56, 920.43, 0.0); MyObj obj3 = new MyObj(8, 4.79, 913.87, 0.0); MyObj obj4 = new MyObj(7, 6.23, 909.08, 0.0); List<MyObj> list = Lists.newArrayList(obj4, obj3, obj2, obj1); MyObj res = list.stream().reduce(new MyObj(0, 0.0, 0.0, 0.0), (prev, curr) -> { curr.setSumVal(prev.getAccVal() + curr.getCurVal()); return curr; }, (a, b) -> a); list.forEach(System.out::println); ``` |
12
Karte 260 天前
```java
public class StreamTest { private List<C> initialSequence() { var res = new ArrayList<C>(); var rand = new Random(0); for (int i = 0; i < 10; i++) { C c = new C(); c.setId(i); c.setCurrent(rand.nextInt(1000)); res.add(c); } return res; } @Test public void stream() { List<C> sequence = initialSequence(); System.out.println("before"); output(sequence); C finalResult = sequence.stream().reduce(new C(), (pre, now) -> { Integer accumulative = Optional.ofNullable(pre.getAccumulative()).orElse(0); now.setAccumulative(accumulative + now.getCurrent()); return now; }); System.out.println("after"); output(sequence); } private void output(List<C> sequence) { for (C c : sequence) { System.out.println(String.format("id: %s, acc: %d", c.getId(), c.getAccumulative())); } } static class C { private Integer id; private Integer accumulative; private Integer current; public Integer getId() { return id; } public void setId(Integer id) { this.id = id; } public Integer getAccumulative() { return accumulative; } public void setAccumulative(Integer accumulative) { this.accumulative = accumulative; } public Integer getCurrent() { return current; } public void setCurrent(Integer current) { this.current = current; } } } ``` 无视 reduce 的结果即可. |
13
nitmali 260 天前
fori 能解决 没必要强求...
|
14
netabare 260 天前 via Android 1
reduce 里面可以是一个列表。当然 java 没有模式匹配写起来比较恶心。
|
15
misdake 260 天前
这种东西应该是实现一个能够累加的迭代器,输出一个累加值(还可以提供当前值)的流
|
16
Ashe007 260 天前 via iPhone
以 ID 为 key ,累加值为 value 的 map 来解决这个问题,无论是 for 还是 stream 都很简单,不熟练先用 for 实现,让 ai 改成 stream 实现不就好了吗?
|
17
Leviathann 260 天前
不就是 scan 吗
或者 reduce 成一个 list `10 7.66 928.09 9 6.56 920.43 8 4.79 913.87 7 6.23 909.08` .split('\n') .reverse() .map(line => line.split(' ')) .map(([id, value, accu]) => ({ id: Number(id), value: Number(value), accu: Number(accu) })) .reduce((result, cur) => { const last = result[result.length - 1] if (last) { result.push({...cur, accu: last.accu + cur.value}) } else { result.push(cur) } return result }, []) |
18
msg7086 259 天前
map+reduce 一般用在可以并行处理的场景里。
你这里是顺序累加,不能乱序执行,不能并行,不如直接一个 for 循环搞定。 |
19
S4msara 259 天前
不非要用 Stream 实现的话可以参考:
```java public List<Record> greeting(List<Record> list) { ListIterator<Record> iterator = list.listIterator(); while (iterator.hasNext()) { Double preTotal = null; if (iterator.previousIndex() != -1) { Record previous = iterator.previous(); preTotal = previous.getTotal(); iterator.next(); } Record next = iterator.next(); if (preTotal != null) { next.setTotal(preTotal + next.getCurr()); } iterator.set(next); } return list; } ``` |
20
siweipancc 250 天前 via iPhone
不要用流,遵循无状态设计必定新增中间类,撸下来性能跟内存消耗远大于常规写法
|