简单描述Java8-Stream中ForEach的运作原理
简单描述Java8-Stream中ForEach的运作原理
由于好久好久没写⽂章了，也没啥时间，今天周末抽个时间写⼀篇关于Java8中的Stream的foreach描述
Stream中ForEach的基本⽤法
可分迭代器 Spliterator
ReferencePipline , ReferencePipline.Head
Stream中可设置isParallel（）和sequential（），在具体运⾏中如何被使⽤
Stream中ForEach的基本⽤法
接⼝
void forEach(Consumer<? super T> action);
使⽤1：
使⽤2：
roster.stream().parallel().ate()).forEach(p -> t.test(p));//也可以实现接⼝
这⾥引⼊了.parallel() 这是并⾏运⾏的标志，还有个sequential() 顺序执⾏，在归约操作之前，这两者可以切换使⽤，但是要慎重。
Parallel()的使⽤考虑到流长度、分割最⼩单位等考虑，他并不是肯定⽐顺序流遍历快，⽽是看流的量，如果⽤到limit这些操作，不建议使⽤并⾏流，物极必反，并⾏流的代价就是消耗cpu，这中间的时间不可估计。
可分迭代器Spliterator
他有⼏个接⼝⽅法
boolean tryAdvance(Consumer<? super T> action);
Spliterator<T> trySplit();
long estimateSize();
int characteristics();
与往常⼀样，T是Spliterator遍历的元素的类型。tryAdvance⽅法的⾏为类似于普通的 Iterator，因为它会按顺序⼀个⼀个使⽤Spliterator中的元素，并且如果还有其他元素要遍历就返回true。但trySplit是专为Spliterator接⼝设计的，因为它可以把⼀些元素划出去分给第⼆个Spliterator（由该⽅法返回），让它们两个并⾏处理。Spliterator还可通过 estimateSize⽅法估计还剩下多少元素要遍历，因为即使不那么确切，能快速算出来是⼀个值也有助于让拆分均匀⼀点。重要的是，要了解这个拆分过程在内部是如何执⾏的，以便在需要时能够掌控它。java stream
实现类：
这是他的实现类（部分），所以为什么LongStream、IntegerStream、DoubleStream、List等能直接forEach并可以并⾏遍历操作归功于Spliterator.
ReferencePipline 与ReferencePipline.Head
ReferencePipeline他是⼀个抽象类，继承AbstractPipeline和实现Stream类，可以理解为⼀个遍历的管道的抽象类。
ReferencePipeline有⼀个静态内部类Head，并且也继承了ReferencePipeline
我们不妨看看Heap相关的⽅法，⾸先我们看下他的构造器
source：可分迭代器
parallel：是否并⾏操作
sourceFlags：输⼊源管道元素类型标志（this.sourceOrOpFlags = sourceFlags & StreamOpFlag.STREAM_MASK;）forEach⽅法的实现
⾸先判断是否使⽤并⾏流，如果不是就是普通的forEach遍历，也就是通过forEachRemaining⽅法(顺序流)。
如果是并⾏流：
通过接⼝TerminalOp调⽤evaluateParallel⽅法，有四种实现REFERENCE, INT_VALUE, LONG_VALUE, DOUBLE_VALUE 看下ForEachOps中有个ForEachOp抽象类实现
Head(Spliterator<?> source,
int sourceFlags, boolean parallel) {
super(source, sourceFlags, parallel);        }
@Override
public  void  forEach (Consumer<? super  E_OUT> action) {
if  (!isParallel()) {
sourceStageSpliterator().forEachRemaining(action);
}
else  {
super .forEach(action);
}
}
@Override
public <S> Void evaluateParallel(PipelineHelper<T> helper,
Spliterator<S> spliterator) {
if (ordered)
new ForEachOrderedTask<>(helper, spliterator, this).invoke();
else
new ForEachTask<>(helper, spliterator, helper.wrapSink(this)).invoke();
return null;
}
看到这⾥的时候已经很显然易见了，Stram分装的foeach最终的运⾏是⽤过jdk7引进fork/join框架。
由于这篇⽂章主要描述关于jdk8中Steam中foreach的原理，下次抽个时间再写⼀篇关于fork/join的运⾏原理。
Stream中可设置isParallel（）和sequential（）
Stream中的顺序遍历和并⾏遍历是可控的，⽐如说map操作是并⾏的，但是filter操作是顺序的，这个都可以的。还是⼀句话，不要盲⽬乱使⽤。
if (!isParallel()) {
sourceStageSpliterator().forEachRemaining(action);
}
else{
super.forEach(action);
}
每次遍历都会判断当前操作是并⾏还是串⾏。
今天先写到这⾥，个时间再详细写写，把⼀些个⼈所觉得有意思的代码程序分享出来

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。