Lazy Evaluation和Eager Evaluation如何在Java 8中运行
作者:互联网
我理解Streams是懒惰的,直到在流上调用终端方法.
我所知道的是,在调用终端方法之后,所有中间方法都按其调用的顺序执行.
但是通过以下程序,我无法理解流是如何工作的.这是代码,我试过了.
import java.util.*;
import java.util.stream.*;
class TestEagerLazy
{
public static void main(String[] args) {
ArrayList<Integer> a = new ArrayList<>();
a.add(4);a.add(5);a.add(8);
a.add(7);a.add(3);a.add(65);
a.add(87);a.add(2);a.add(12);
a.add(58);a.add(42);
Stream<Integer> st = a.stream().filter(b->{System.out.println("Tested: " + b);return (b%2)==0;});
Spliterator<Integer> it = st.spliterator();
System.out.println("\n\nIterator Results:");
while(it.tryAdvance((j)->System.out.println("iter: "+j)));
System.out.println("Last Statement");
}
}
我期望在流的spliterator上假设tryAdvance的输出如下:
Iterator Results:
Tested: 4
Tested: 5
Tested: 8
Tested: 7
Tested: 3
Tested: 65
Tested: 87
Tested: 2
Tested: 12
Tested: 58
Tested: 42
iter: 4
iter: 8
iter: 2
iter: 12
iter: 58
iter: 42
Last Statement
但我得到的输出如下:
Iterator Results:
Tested: 4
iter: 4
Tested: 5
Tested: 8
iter: 8
Tested: 7
Tested: 3
Tested: 65
Tested: 87
Tested: 2
iter: 2
Tested: 12
iter: 12
Tested: 58
iter: 58
Tested: 42
iter: 42
Last Statement
什么是确切的程序流程?程序如何从tryAdvance流向流上并返回.
解决方法:
无状态流旨在处理可能无限量的元素.为此,流不能尝试一次评估所有元素上的每个操作.
顺序流总是一次执行一个元素的管道.在下一个元素开始之前,每个元素都会遍历整个管道.这是允许惰性评估有效的原因.它允许流短路,例如findFirst
或allMatch
.如果在每个阶段一次处理所有元素,则流将无法处理无限数据源,例如从Stream.iterate
开始.
代码的输出表明元素一次一个地通过管道:
Iterator Results:
Tested: 4 // starting 1st element
iter: 4 // ending 1st element
Tested: 5 // starting 2nd element (fails the filter)
Tested: 8 // starting 3rd element
iter: 8 // ending 3rd element
Tested: 7 // starting 4th element (fails the filter)
...
Last Statement
这些行为在JavaDoc中进行了更全面的解释.
标签:java,java-8,lazy-evaluation 来源: https://codeday.me/bug/20190828/1755367.html