懒惰流在Java8中是如何实现的？

Answer 1

为什么你需要反思才能变得懒惰？例如，考虑这个类：

class LazySeq<T> {

    private final List<T> list;
    private Predicate<? super T> predicate;

    public LazySeq(List<T> input) {
        this.list = new ArrayList<>(input);
    }

    //Here you just store the predicate, but you don't perform a filtering
    //You could also return a new LazySeq with a new state
    public LazySeq<T> filter(Predicate<? super T> predicate) {
        this.predicate = predicate;
        return this;
    }

    public void forEach(Consumer<? super T> consumer){
        if(predicate == null) {
            list.forEach(consumer);
        } else {
            for(T elem : list) {
                if(predicate.test(elem)) {
                    consumer.accept(elem);
                }
            }
        }
    }
}

在惰性seq上调用filter时，筛选不会立即发生，例如：

LazySeq<Integer> lazySeq = new LazySeq<>(Arrays.asList(1, 2, 3, 4));
lazySeq = lazySeq.filter(i -> i%2 == 0);

如果在调用filter之后看到序列的内容，您将看到它总是1,2,3,4。但是，当调用终端操作（如foreach）时，筛选将在使用使用者之前完成。例如：

lazySeq.filter(i -> i%2 == 0).forEach(System.out::println);