我有一個像這樣的“請求”對象列表(id,金額,價格)

List requests = Arrays.asList(

new Request(id++, 20, 59.28),

new Request(id++, 10, 61.23),

new Request(id++, 30, 60.67),

new Request(id++, 25, 60.16),

new Request(id++, 60, 59.67));

我想在一次迭代中計算兩個指標 – 總和(金額)和總和(金額*價格).我需要它們來計算平均價格：總和(金額*價格)/總和(金額).

考慮到我想使用Java 8流,我發現的唯一變體是將值映射到Pair對象并實現自定義使用者：

static class Aggregate implements Consumer> {

private double count = 0L;

private double sum = 0L;

public double average() {

return count > 0 ? sum/(double) count : 0;

}

public void combine(Aggregate other) {

count += other.count;

sum += other.sum;

}

@Override

public void accept(Pair data) {

this.count += data.getLeft();

this.sum += data.getLeft() * data.getRight();

}

}

Double avgPrice = requests.stream()

.map(e -> Pair.of(e.getAmount(), e.getPrice()))

.collect(Aggregate::new, Aggregate::accept, Aggregate::combine)

.average();

這種方法看起來很混亂 – 我們必須為每個條目創建額外的Pair對象:(

有誰知道更好的解決方案？

最佳答案 當然.您需要自定義聚合,但不需要對：

static class Aggregate {

private long count = 0L;

private double sum = 0L;

double average() { return sum / count; }

void merge(Aggregate other) {

count += other.count;

sum += other.sum;

}

void add(int count, double value) {

this.count += count;

this.sum += count * value;

}

}

}

requests.stream().collect(

Aggregate::new,

(aggr, request) -> aggr.add(request.getCount(), request.getPrice()),

Aggregate::merge)

.average();

而且您實際上并不需要實現Consumer.

老實說,多通道解決方案可能非常快,也更簡單……

requests.stream()

.mapToDouble(request -> request.getCount() * request.getPrice())

.sum()

/ requests.stream().mapToLong(Request::getCount).sum();

總結

以上是生活随笔為你收集整理的java 聚合函数_如何使用Java流计算两个聚合函数？的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。