Java8 Stream()与ParallelStream()区别
Stream
无状态：指元素的处理不受之前元素的影响；
有状态：指该操作只有拿到所有元素之后才能继续下去。
非短路操作：指必须处理所有元素才能得到最终结果；
短路操作：指遇到某些符合条件的元素就可以得到最终结果，如 A || B，只要A为true，则无需判断B的结果。
ParallelStream
对于ParallelStream，需要知道的是里面的执行是异步的，并且使用的线程池是ForkJoinPool测试数据mon，可以通过设置-Djava.util.concurrent.ForkJoinPool测试数据mon.parallelism = N来调整线程池的大小；
ParallelStream的作用
Stream具有平行处理能力，处理的过程会分而治之，也就是将一个大任务切分成多个小任务，这表示每个任务都是一个操作，因此像以下的程式片段：
|
1 2 |
List<Integer> numbers = Arrays.asList( 1 , 2 , 3 , 4 , 5 , 6 , 7 , 8 , 9 ); numbers.parallelStream().forEach(System.out::println); |
得到的展示顺序不一定会是1、2、3、4、5、6、7、8、9，而可能是任意的顺序。 得到的结论就是parallelStream()每次执行的结果都不相同，与多线程程序中执行的结果类似 。如果希望最后顺序是按照原来Stream的数据顺序，那可以调用forEachOrdered()。
例如：
|
1 2 |
List<Integer> numbers = Arrays.asList( 1 , 2 , 3 , 4 , 5 , 6 , 7 , 8 , 9 ); numbers.parallelStream().forEachOrdered(System.out::println); |
你得到的展示顺序就是1、2、3、4、5、6、7、8、9。
Java8并行流parallelStream()和stream()的区别就是支持并行执行，提高程序运行效率。但是如果使用不当可能会发生线程安全的问题。
其他同类知识点：
1、Java集合Stream类filter的使用；
2、Java中的排序问题（Java8新特性 stream流、stream多字段排序）；
parallelStream与stream效率比较
结论
parallel线程不安全
parallel的效率，因为是多线程，默认线程数量是计算器处理器的数量
代码
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 |
public class StreamTest { @Test public void streamVs(){ List<Integer> list1 = new ArrayList<>( 10000 ); List<Integer> list2 = new ArrayList<>( 10000 ); List<Integer> list3 = new ArrayList<>( 10000 ); Lock lock = new ReentrantLock(); IntStream.range( 0 , 10000 ).forEach(list1::add); IntStream.range( 0 , 10000 ).parallel().forEach(list2::add); IntStream.range( 0 , 10000 ).parallel().forEach(i -> { lock.lock(); try { list3.add(i); } finally { lock.unlock(); } }); System.out.println( "串行执行的大小：" + list1.size()); System.out.println( "并行执行的大小：" + list2.size()); System.out.println( "加锁并行执行的大小：" + list3.size()); } @Test public void streamVs2(){ List<Person> persons = constructPersons(); doFor(persons); doStream(persons); doParallelStream(persons); } /** * 构造数据 * * @return */ public List<Person> constructPersons() { List<Person> persons = new ArrayList<Person>(); for ( int i = 0 ; i < 5 ; i++) { Person p = new Person(i, "name" + i, "sex" + i, i); persons.add(p); } return persons; } /** * for * * @param persons */ public void doFor(List<Person> persons) { long start = System.currentTimeMillis(); for (Person p : persons) { try { Thread.sleep( 1000 ); } catch (InterruptedException e) { } //System.out.println(p.name); } long end = System.currentTimeMillis(); System.out.println( "doFor cost:" + (end - start)); } /** * 顺序流 * * @param persons */ public void doStream(List<Person> persons) { long start = System.currentTimeMillis(); persons.stream().forEach(x -> { try { Thread.sleep( 1000 ); } catch (InterruptedException e) { } //System.out.println(x.name); }); long end = System.currentTimeMillis(); System.out.println( "doStream cost:" + (end - start)); } /** * 并行流 * * @param persons */ public void doParallelStream(List<Person> persons) { long start = System.currentTimeMillis(); persons.parallelStream().forEach(x -> { try { Thread.sleep( 1000 ); } catch (InterruptedException e) { } //System.out.println(x.name); }); long end = System.currentTimeMillis(); System.out.println( "doParallelStream cost:" + (end - start)); } } class Person { int id; String name; String sex; float height; public Person( int id, String name, String sex, float height) { this .id = id; this .name = name; this .sex = sex; this .height = height; } } |
测试截图
串行执行的大小：10000
并行执行的大小：7219
加锁并行执行的大小：10000
|
1 2 3 |
doFor cost: 5012 doStream cost: 5073 doParallelStream cost: 2013 |
以上为个人经验，希望能给大家一个参考，也希望大家多多支持。
原文链接：https://blog.csdn.net/weixin_44299027/article/details/102615197
查看更多关于Java8的Stream()与ParallelStream()的区别说明的详细内容...