数据流中的移动平均值

/*
 * 思路:
 * 使用Java Stream API，我们可以通过流操作简化代码。需要注意的是，Java Stream API通常用于一次性操作，
 * 而不是持续的数据流。因此，仍然需要使用队列来存储最近的n个值。
 */
import java.util.LinkedList;
import java.util.Queue;
import java.util.stream.Collectors;
 
public class MovingAverageStream {
    private final Queue<Integer> queue;
    private final int maxSize;
    private double sum;
 
    public MovingAverageStream(int size) {
        this.queue = new LinkedList<>();
        this.maxSize = size;
        this.sum = 0;
    }
 
    public double next(int val) {
        if (queue.size() == maxSize) {
            sum -= queue.poll();
        }
        queue.offer(val);
        sum += val;
        return queue.stream().mapToDouble(num -> num).average().orElse(0.0);
    }
 
    public static void main(String[] args) {
        MovingAverageStream m = new MovingAverageStream(3);
        System.out.println(m.next(1)); // 1.0
        System.out.println(m.next(10)); // 5.5
        System.out.println(m.next(3)); // 4.66667
        System.out.println(m.next(5)); // 6.0
    }
}