Stream多线程并行数据处理
Posted
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Stream多线程并行数据处理相关的知识，希望对你有一定的参考价值。
参考技术A 起初，我写一个循环list的stram流， list.stram().filter(item->item>0).map(item->item.get(”id“)).parallel().collect(Collectors.toList) 的时候，想用并行流去处理，但是不了解filter与map并行，还是filter与map内部并行。一个顺序执行的流转变成一个并行的流只要调用 parallel()方法，一个自定义list的例子：
return Stream.iterate(1L, i -> i +1).limit(n).parallel().reduce(0L,Long::sum);
一个并发流转成顺序的流只要调用sequential()方法
stream.parallel() .filter(...) .sequential() .map(...) .parallel() .reduce();
这两个方法可以多次调用， 只有最后一个调用决定这个流是顺序的还是并发的。
本文地址 Stream多线程并行数据处理
以上是关于Stream多线程并行数据处理的主要内容，如果未能解决你的问题，请参考以下文章