Stream.forEach和Collection.forEach
一、定义
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()在每次运行会产生不同的结果。一个可能的输出是:
三、自定义迭代器
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()只是从列表中逐个获取元素,会忽略迭代器。
|