东莞百度推广优化公司,seo推广公司招商,郴州高端网站建设,广告设计与制作专业就业岗位Gitchat连接
https://gitbook.cn/gitchat/activity/5f85696aad812d16b498848c
简介
从底层#xff0c;从原理#xff0c;我们来重学一次 Java。Stream 是JDK8中新引入的#xff0c;方便了数据列表的过滤、投影、遍历等各种处理#xff0c;他的源码及实现是怎样的呢…Gitchat连接
https://gitbook.cn/gitchat/activity/5f85696aad812d16b498848c
简介
从底层从原理我们来重学一次 Java。Stream 是JDK8中新引入的方便了数据列表的过滤、投影、遍历等各种处理他的源码及实现是怎样的呢
本系列秉承所有结论尽量从源码中来没有源码的尽量标明出处。相关源码会附着在文章中读本文即可不用再自行查找源码及资料学习方便大家充分利用路上的碎片时间。
本篇 Chat 从Stream示例开始讲解构建Stream源码分析了非并行forEach各种情况的源码逻辑讲解了Stream的各个接口及应用示例帮助大家深入理解和学习 JDK 源码。
本文包含以下内容
列表获取流 Collection.stream() 数组获取流 Arrays.stream(T[] array)Arrays.stream(T[] array, int startInclusive, int endExclusive) 直接构建流 Stream.of StreamSupport 构造函数stream(Spliterator spliterator, boolean parallel) Collection.spliterator() fail-fast快速失败机制 非并行forEach stream直接进行forEach Arrays.stream的forEach Arrays.spliterator(T[] array, int startInclusive, int endExclusive)Spliterators.spliterator(Object[] array, int fromIndex, int toIndex, int additionalCharacteristics)ArraySpliterator.forEachRemaining(Consumer? super T action)总结 ArrayList stream的forEach Collection.stream()ArrayList.spliterator()ArrayList.ArrayListSpliteratorArrayList.ArrayListSpliterator.forEachRemaining总结 stream进行一次中间操作再forEach ReferencePipeline.filterReferencePipeline.StatelessOpReferencePipeline.forEachForEachOpsForEachOps.makeRef(Consumer? super T action, boolean ordered) ForEachOpForEachOp.OfRef AbstractPipeline.evaluateForEachOps.ForEachOp.evaluateSequentialAbstractPipeline.wrapAndCopyIntoAbstractPipeline.wrapSinkAbstractPipeline.copyIntoSink.ChainedReference总结 Stream 接口定义接口继承结构filter(Predicate? super T predicate)map(Function? super T, ? extends R mapper)mapToInt(ToIntFunction? super T mapper)mapToLong(ToLongFunction? super T mapper)mapToDouble(ToDoubleFunction? super T mapper)flatMap(Function? super T, ? extends Stream? extends R mapper)flatMapToInt(Function? super T, ? extends IntStream mapper)flatMapToLong(Function? super T, ? extends LongStream mapper)flatMapToDouble(Function? super T, ? extends DoubleStream mapper)distinct()sorted()sorted(Comparator? super T comparator)peek(Consumer? super T action)limit(long maxSize)skip(long n)forEach(Consumer? super T action)forEachOrdered(Consumer? super T action)toArray(IntFunctionA[] generator)reduce(T identity, BinaryOperator accumulator)reduce(BinaryOperator accumulator)reduce(U identity,BiFunctionU, ? super T, U accumulator,BinaryOperatorU combiner) 调用示例1调用示例2调用示例3 collect(SupplierR supplier, BiConsumerR, ? super T accumulator, BiConsumerR, R combiner) 调用示例1调用示例2调用示例3 collect(Collector? super T, A, R collector) 流转List示例GroupBy分组示例 min(Comparator? super T comparator)max(Comparator? super T comparator)count()anyMatch(Predicate? super T predicate) 调用示例1调用示例2 allMatch(Predicate? super T predicate) 调用示例1调用示例2 noneMatch(Predicate? super T predicate) 调用示例1调用示例2 findFirst()findAny()builder()empty()of(T t)StreamT of(T… values)iterate(final T seed, final UnaryOperatorT f) Streams.NONESpliterators.spliteratorUnknownSize(Iterator? extends T iterator, int characteristics)调用示例 generate(Supplier s) StreamSpliteratorsStreamSpliterators.InfiniteSupplyingSpliteratorStreamSpliterators.InfiniteSupplyingSpliterator.OfRefT调用示例 concat(Stream? extends T a, Stream? extends T b) Streams.composedClose(BaseStream?, ? a, BaseStream?, ? b)Throwable.addSuppressed(Throwable exception)Throwable.SUPPRESSED_SENTINELThrowable.suppressedExceptions Stream.Builder accept(T t)add(T t)build() BaseStream 接口定义接口继承结构 AutoCloseable 接口定义接口继承结构close()try-with-resources
