Java8流中的懒惰sorted()，需要在每次迭代时使用

Question

我正在寻找一种用Java8流模拟以下行为的方法。给定一个年份流，对它们进行排序，以便输出前10个值，这样，在输出一年之后，该值将减少，并且迭代重新开始再一次resorting：

如果我输入2005年、2020年、2000年、1967年和2018年，我期望以10为限得出以下结果：

2020
2019
2018 2018  
2017 2017
2016 2016 2016
2015 ...

我使用的测试是：

public class LazyTest {

    public static void main(String[] args) {
        Stream.of(2005,2020,2000,1967,2018)
              .map(YearWrapper::new)
              .sorted()
              .limit(10)
              .peek(year -> year.decreaseYear())
              .forEach(System.out::println);
    }

    public static class YearWrapper implements Comparable<YearWrapper>{
        private int currentYear;

        public YearWrapper(int year){
            this.currentYear=year;
        }
        public void decreaseYear(){
            currentYear--;
        }
        @Override
        public int compareTo(YearWrapper yearsToCompare) {
            return Integer.compare(yearsToCompare.currentYear, this.currentYear);
        }

        @Override
        public String toString(){
            return String.valueOf(currentYear);
        }
    }
}

但看起来sorted（）一点也不懒。整个排序在beggining处完成一次，因此在任何进一步操作之前要计算顺序，因此，示例的5个值是按顺序逐个传递的，因此drecess（）对html" target="_blank">迭代没有实际影响。

在流式传输下一个元素之前，有什么方法可以使sorted（）变得懒散并再次应用于剩余的元素吗？

任何其他近距离接近将非常感谢！！

Answer 1

我是否正确理解你想从列表中取最大的数字，递减它，放回列表中，重复10次？

如果是,则这是PriorityQueue的作业：

PriorityQueue<Integer> queue = Stream.of(2005,2020,2000,1967,2018)
        .collect(toCollection(() -> new PriorityQueue(reverseOrder())));

Stream.generate(() -> {
    Integer year = queue.poll();
    queue.add(year - 1);
    return year;
}).limit(10).forEach(System.out::println);