Java8的Stream()與ParallelStream()的區(qū)別說明
Java8 Stream()與ParallelStream()區(qū)別
Stream
無狀態(tài):指元素的處理不受之前元素的影響;
有狀態(tài):指該操作只有拿到所有元素之后才能繼續(xù)下去。
非短路操作:指必須處理所有元素才能得到最終結(jié)果;
短路操作:指遇到某些符合條件的元素就可以得到最終結(jié)果,如 A || B,只要A為true,則無需判斷B的結(jié)果。
ParallelStream
對于ParallelStream,需要知道的是里面的執(zhí)行是異步的,并且使用的線程池是ForkJoinPool.common,可以通過設(shè)置-Djava.util.concurrent.ForkJoinPool.common.parallelism = N來調(diào)整線程池的大??;
ParallelStream的作用
Stream具有平行處理能力,處理的過程會分而治之,也就是將一個大任務(wù)切分成多個小任務(wù),這表示每個任務(wù)都是一個操作,因此像以下的程式片段:
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,而可能是任意的順序。得到的結(jié)論就是parallelStream()每次執(zhí)行的結(jié)果都不相同,與多線程程序中執(zhí)行的結(jié)果類似。如果希望最后順序是按照原來Stream的數(shù)據(jù)順序,那可以調(diào)用forEachOrdered()。
例如:
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()的區(qū)別就是支持并行執(zhí)行,提高程序運(yùn)行效率。但是如果使用不當(dāng)可能會發(fā)生線程安全的問題。
其他同類知識點(diǎn):
1、Java集合Stream類filter的使用;
2、Java中的排序問題(Java8新特性 stream流、stream多字段排序);
parallelStream與stream效率比較
結(jié)論
parallel線程不安全
parallel的效率,因?yàn)槭嵌嗑€程,默認(rèn)線程數(shù)量是計算器處理器的數(shù)量
代碼
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("串行執(zhí)行的大?。? + list1.size()); System.out.println("并行執(zhí)行的大?。? + list2.size()); System.out.println("加鎖并行執(zhí)行的大?。? + list3.size()); } @Test public void streamVs2(){ List<Person> persons = constructPersons(); doFor(persons); doStream(persons); doParallelStream(persons); } /** * 構(gòu)造數(shù)據(jù) * * @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; } }
測試截圖
串行執(zhí)行的大?。?0000
并行執(zhí)行的大?。?219
加鎖并行執(zhí)行的大?。?0000
doFor cost:5012 doStream cost:5073 doParallelStream cost:2013
以上為個人經(jīng)驗(yàn),希望能給大家一個參考,也希望大家多多支持腳本之家。
相關(guān)文章
Spring MVC實(shí)現(xiàn)的登錄攔截器代碼分享
這篇文章主要介紹了Spring MVC實(shí)現(xiàn)的登錄攔截器代碼分享,涉及攔截器的簡單介紹,攔截器和過濾器的區(qū)以及攔截器實(shí)現(xiàn)代碼等相關(guān)內(nèi)容,這里分享給大家,供需要的朋友參考。2017-10-10Java實(shí)現(xiàn)將Word轉(zhuǎn)換成Html的示例代碼
在業(yè)務(wù)中,常常會需要在瀏覽器中預(yù)覽Word文檔,或者需要將Word文檔轉(zhuǎn)成HTML文件保存,本文主要為大家詳細(xì)介紹了Java實(shí)現(xiàn)Word轉(zhuǎn)換成Html的相關(guān)方法,希望對大家有所幫助2024-02-02SpringBoot3+SpringSecurity6前后端分離的項(xiàng)目實(shí)踐
SpringSecurity6 的用法和以前版本的有較大差別,本文主要介紹了SpringBoot3+SpringSecurity6前后端分離的項(xiàng)目實(shí)踐,具有一定的參考價值,感興趣的可以了解一下2023-12-12如何修改HttpServletRequest中header中的信息
這篇文章主要介紹了如何修改HttpServletRequest中header中的信息,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2022-02-02jpa多條件查詢重寫Specification的toPredicate方法
這篇文章主要介紹了多條件查詢重寫Specification的toPredicate方法,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2021-11-11最新jsonwebtoken-jwt 0.12.3 基本使用小結(jié)
這篇文章主要介紹了最新jsonwebtoken-jwt 0.12.3 基本使用小結(jié),本文通過實(shí)例代碼給大家介紹的非常詳細(xì),對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下2023-12-12java 開發(fā)中網(wǎng)絡(luò)編程之IP、URL詳解及實(shí)例代碼
這篇文章主要介紹了java 開發(fā)中網(wǎng)絡(luò)編程之IP、URL詳解及實(shí)例代碼的相關(guān)資料,需要的朋友可以參考下2017-03-03