Stream.forEach和Collection.forEach

• 一、定义
• 二、执行顺序
• • 1、Parallel Stream
• 三、自定义迭代器

一、定义

forEach由 Iterable.forEach 定义，而stream.forEach 由 Stream.forEach 定义。 Stream.forEach 的定义允许以任何顺序处理元素 - 即使对于顺序流也是如此。 但对于并行流， Stream.forEach 很可能会无序处理元素。

Iterable.forEach 从源获取一个Iterator并在其上调用 forEachRemaining（）。

Stream.forEach 的实现都将创建一个源自其中一个迭代器的Spliterator，然后在Iterator上调用 forEachRemaining

二、执行顺序

Collection.forEach()使用集合的迭代器（如果指定了一个），集合里元素的处理顺序是明确的。相反，Collection.stream().forEach()的处理顺序是不明确的。

1、Parallel Stream

public void test29() {
        List<String> list = Arrays.asList("A","B","C","D");
        list.forEach(System.out::print);
        System.out.println("=================================================");
        list.stream().forEach(System.out::print);
        System.out.println("=================================================");
        list.parallelStream().forEach(System.out::print);
        System.out.println("=================================================");
    }
           

我们会看到 list.forEach()以插入顺序处理元素，而 list.parallelStream().forEach()在每次运行会产生不同的结果。一个可能的输出是：

三、自定义迭代器

/**
 * @author lichangyuan
 * @create 2022-03-03 16:05
 */
public class ReverseList extends ArrayList<String> {

    @Override
    public Iterator<String> iterator() {

        int startlndex = this.size() - 1;
        List<String> list = this;

        Iterator<String> it = new Iterator<String>() {

            private int currentlndex = startlndex;

            @Override
            public boolean hasNext() {
                return currentlndex >= 0;
            }

            @Override
            public String next() {
                String next = list.get(currentlndex);
                currentlndex--;
                return next;
            }

            @Override
            public void remove() {
                throw new UnsupportedOperationException();
            }
        };
        return it;
    }
}
           

@Test
    public void test30() {
        List<String> list = Arrays.asList("A","B","C","D");
        List<String> myList = new ReverseList();
        myList.addAll(list);

        myList.forEach(System.out::print);
        System.out.println("=================================================");
        myList.stream().forEach(System.out::print);
        System.out.println("=================================================");
        myList.parallelStream().forEach(System.out::print);
        System.out.println("=================================================");
    }
           

结果不同的原因是在列表中使用的 forEach()会使用自定义迭代器，而 stream().forEach()只是从列表中逐个获取元素，会忽略迭代器。