如何将for循环转换为Stream流实现等价平均价差计算逻辑

DevOps 小满

2026-8-29

使用Java Stream实现Tick价差平均值计算

首先对齐原代码的核心逻辑：原循环中的判断条件(t.getAskPrice() == 0 && t.getBidPrice() == 0) || (t.getAskPrice() == 0) || (t.getBidPrice() == 0)可做等价简化，本质是只要askPrice或bidPrice任意一个为0，就不对总和做累加、也不增加计数，这类元素可以直接通过过滤排除，不需要额外处理加0的冗余逻辑。

Java 12+ 实现（和原逻辑100%对齐）

用Collectors.teeing同时收集价差总和、有效元素计数两个值，直接计算平均值，无有效元素时和原代码行为一致返回NaN：

double avg = TickQueue.stream()
        .filter(t -> t.getAskPrice() != 0 && t.getBidPrice() != 0)
        .collect(Collectors.teeing(
                Collectors.summingDouble(t -> t.getAskPrice() - t.getBidPrice()),
                Collectors.counting(),
                (tot, counter) -> tot / counter
        ));

Java 8 兼容实现

用内置的DoubleSummaryStatistics统计类实现，注意默认无有效元素时方法会返回0.0，如果需要和原代码完全一致返回NaN，可以加一层判断：

DoubleSummaryStatistics stats = TickQueue.stream()
        .filter(t -> t.getAskPrice() != 0 && t.getBidPrice() != 0)
        .mapToDouble(t -> t.getAskPrice() - t.getBidPrice())
        .summaryStatistics();

// 完全对齐原代码行为：无有效元素时返回NaN
double avg = stats.getCount() == 0 ? 0.0 / 0.0 : stats.getAverage();