欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Java8的Stream()與ParallelStream()的區(qū)別說(shuō)明

 更新時(shí)間:2021年07月28日 10:11:35   作者:No8g攻城獅  
這篇文章主要介紹了Java8的Stream()與ParallelStream()的區(qū)別說(shuō)明,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教

Java8 Stream()與ParallelStream()區(qū)別

Stream

無(wú)狀態(tài):指元素的處理不受之前元素的影響;

有狀態(tài):指該操作只有拿到所有元素之后才能繼續(xù)下去。

非短路操作:指必須處理所有元素才能得到最終結(jié)果;

短路操作:指遇到某些符合條件的元素就可以得到最終結(jié)果,如 A || B,只要A為true,則無(wú)需判斷B的結(jié)果。

ParallelStream

對(duì)于ParallelStream,需要知道的是里面的執(zhí)行是異步的,并且使用的線程池是ForkJoinPool.common,可以通過(guò)設(shè)置-Djava.util.concurrent.ForkJoinPool.common.parallelism = N來(lái)調(diào)整線程池的大小;

ParallelStream的作用

Stream具有平行處理能力,處理的過(guò)程會(huì)分而治之,也就是將一個(gè)大任務(wù)切分成多個(gè)小任務(wù),這表示每個(gè)任務(wù)都是一個(gè)操作,因此像以下的程式片段:

List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9); 
numbers.parallelStream().forEach(System.out::println);

得到的展示順序不一定會(huì)是1、2、3、4、5、6、7、8、9,而可能是任意的順序。得到的結(jié)論就是parallelStream()每次執(zhí)行的結(jié)果都不相同,與多線程程序中執(zhí)行的結(jié)果類似。如果希望最后順序是按照原來(lái)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)可能會(huì)發(fā)生線程安全的問(wèn)題。

其他同類知識(shí)點(diǎn):

1、Java集合Stream類filter的使用;

2、Java中的排序問(wèn)題(Java8新特性 stream流、stream多字段排序);

parallelStream與stream效率比較

結(jié)論

parallel線程不安全

parallel的效率,因?yàn)槭嵌嗑€程,默認(rèn)線程數(shù)量是計(jì)算器處理器的數(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;
    }
}

測(cè)試截圖

串行執(zhí)行的大?。?0000

并行執(zhí)行的大?。?219

加鎖并行執(zhí)行的大?。?0000

doFor cost:5012
doStream cost:5073
doParallelStream cost:2013

以上為個(gè)人經(jīng)驗(yàn),希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。

相關(guān)文章

  • Java中方法使用的深入講解

    Java中方法使用的深入講解

    這篇文章主要給大家介紹了關(guān)于Java中方法使用的相關(guān)資料,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2020-10-10
  • 詳解解決IDEA2020.1版本的lombok插件問(wèn)題

    詳解解決IDEA2020.1版本的lombok插件問(wèn)題

    這篇文章主要介紹了詳解解決IDEA2020.1版本的lombok插件問(wèn)題。文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2020-11-11
  • Spring MVC實(shí)現(xiàn)的登錄攔截器代碼分享

    Spring MVC實(shí)現(xiàn)的登錄攔截器代碼分享

    這篇文章主要介紹了Spring MVC實(shí)現(xiàn)的登錄攔截器代碼分享,涉及攔截器的簡(jiǎn)單介紹,攔截器和過(guò)濾器的區(qū)以及攔截器實(shí)現(xiàn)代碼等相關(guān)內(nèi)容,這里分享給大家,供需要的朋友參考。
    2017-10-10
  • Java實(shí)現(xiàn)將Word轉(zhuǎn)換成Html的示例代碼

    Java實(shí)現(xiàn)將Word轉(zhuǎn)換成Html的示例代碼

    在業(yè)務(wù)中,常常會(huì)需要在瀏覽器中預(yù)覽Word文檔,或者需要將Word文檔轉(zhuǎn)成HTML文件保存,本文主要為大家詳細(xì)介紹了Java實(shí)現(xiàn)Word轉(zhuǎn)換成Html的相關(guān)方法,希望對(duì)大家有所幫助
    2024-02-02
  • SpringBoot3+SpringSecurity6前后端分離的項(xiàng)目實(shí)踐

    SpringBoot3+SpringSecurity6前后端分離的項(xiàng)目實(shí)踐

    SpringSecurity6 的用法和以前版本的有較大差別,本文主要介紹了SpringBoot3+SpringSecurity6前后端分離的項(xiàng)目實(shí)踐,具有一定的參考價(jià)值,感興趣的可以了解一下
    2023-12-12
  • 如何修改HttpServletRequest中header中的信息

    如何修改HttpServletRequest中header中的信息

    這篇文章主要介紹了如何修改HttpServletRequest中header中的信息,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2022-02-02
  • jpa多條件查詢重寫(xiě)Specification的toPredicate方法

    jpa多條件查詢重寫(xiě)Specification的toPredicate方法

    這篇文章主要介紹了多條件查詢重寫(xiě)Specification的toPredicate方法,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2021-11-11
  • 詳解java調(diào)用存儲(chǔ)過(guò)程并封裝成map

    詳解java調(diào)用存儲(chǔ)過(guò)程并封裝成map

    這篇文章主要介紹了詳解java調(diào)用存儲(chǔ)過(guò)程并封裝成map的相關(guān)資料,希望通過(guò)本文能幫助到大家實(shí)現(xiàn)這樣的功能,需要的朋友可以參考下
    2017-09-09
  • 最新jsonwebtoken-jwt 0.12.3 基本使用小結(jié)

    最新jsonwebtoken-jwt 0.12.3 基本使用小結(jié)

    這篇文章主要介紹了最新jsonwebtoken-jwt 0.12.3 基本使用小結(jié),本文通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
    2023-12-12
  • java 開(kāi)發(fā)中網(wǎng)絡(luò)編程之IP、URL詳解及實(shí)例代碼

    java 開(kāi)發(fā)中網(wǎng)絡(luò)編程之IP、URL詳解及實(shí)例代碼

    這篇文章主要介紹了java 開(kāi)發(fā)中網(wǎng)絡(luò)編程之IP、URL詳解及實(shí)例代碼的相關(guān)資料,需要的朋友可以參考下
    2017-03-03

最新評(píng)論