欧美亚洲中文,在线国自产视频,欧洲一区在线观看视频,亚洲综合中文字幕在线观看

      1. <dfn id="rfwes"></dfn>
          <object id="rfwes"></object>
        1. 站長資訊網(wǎng)
          最全最豐富的資訊網(wǎng)站

          Java8中Stream詳細(xì)用法歸納

          本篇文章給大家?guī)砹岁P(guān)于java的相關(guān)知識,其中主要介紹了關(guān)于Stream詳細(xì)用法的相關(guān)問題,版本新增的Stream,配合同版本出現(xiàn)的Lambda ,給我們操作集合(Collection)提供了極大的便利,下面一起來看一下,希望對大家有幫助。

          Java8中Stream詳細(xì)用法歸納

          程序員必備接口測試調(diào)試工具:立即使用
          Apipost = Postman + Swagger + Mock + Jmeter
          Api設(shè)計(jì)、調(diào)試、文檔、自動(dòng)化測試工具
          后端、前端、測試,同時(shí)在線協(xié)作,內(nèi)容實(shí)時(shí)同步

          推薦學(xué)習(xí):《java視頻教程》

          一、概述

          Java 8 是一個(gè)非常成功的版本,這個(gè)版本新增的Stream,配合同版本出現(xiàn)的Lambda ,給我們操作集合(Collection)提供了極大的便利。Stream流是JDK8新增的成員,允許以聲明性方式處理數(shù)據(jù)集合,可以把Stream流看作是遍歷數(shù)據(jù)集合的一個(gè)高級迭代器。Stream 是 Java8 中處理集合的關(guān)鍵抽象概念,它可以指定你希望對集合進(jìn)行的操作,可以執(zhí)行非常復(fù)雜的查找/篩選/過濾、排序、聚合和映射數(shù)據(jù)等操作。使用Stream API 對集合數(shù)據(jù)進(jìn)行操作,就類似于使用 SQL 執(zhí)行的數(shù)據(jù)庫查詢。也可以使用 Stream API 來并行執(zhí)行操作。簡而言之,Stream API 提供了一種高效且易于使用的處理數(shù)據(jù)的方式。

          1、使用流的好處

          代碼以聲明性方式書寫,說明想要完成什么,而不是說明如何完成一個(gè)操作。
          可以把幾個(gè)基礎(chǔ)操作連接起來,來表達(dá)復(fù)雜的數(shù)據(jù)處理的流水線,同時(shí)保持代碼清晰可讀。

          2、流是什么?

          從支持?jǐn)?shù)據(jù)處理操作的源生成元素序列.數(shù)據(jù)源可以是集合,數(shù)組或IO資源。

          從操作角度來看,流與集合是不同的. 流不存儲(chǔ)數(shù)據(jù)值; 流的目的是處理數(shù)據(jù),它是關(guān)于算法與計(jì)算的。

          如果把集合作為流的數(shù)據(jù)源,創(chuàng)建流時(shí)不會(huì)導(dǎo)致數(shù)據(jù)流動(dòng); 如果流的終止操作需要值時(shí),流會(huì)從集合中獲取值; 流只使用一次。

          流中心思想是延遲計(jì)算,流直到需要時(shí)才計(jì)算值。
          Java8中Stream詳細(xì)用法歸納
          Stream可以由數(shù)組或集合創(chuàng)建,對流的操作分為兩種:

          中間操作,每次返回一個(gè)新的流,可以有多個(gè)。

          終端操作,每個(gè)流只能進(jìn)行一次終端操作,終端操作結(jié)束后流無法再次使用。終端操作會(huì)產(chǎn)生一個(gè)新的集合或值。

          特性:

          不是數(shù)據(jù)結(jié)構(gòu),不會(huì)保存數(shù)據(jù)。

          不會(huì)修改原來的數(shù)據(jù)源,它會(huì)將操作后的數(shù)據(jù)保存到另外一個(gè)對象中。(保留意見:畢竟peek方法可以修改流中元素)

          惰性求值,流在中間處理過程中,只是對操作進(jìn)行了記錄,并不會(huì)立即執(zhí)行,需要等到執(zhí)行終止操作的時(shí)候才會(huì)進(jìn)行實(shí)際的計(jì)算。

          二、分類

          Java8中Stream詳細(xì)用法歸納

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

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

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

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

          三、Stream的創(chuàng)建

          Stream可以通過集合數(shù)組創(chuàng)建。

          1、通過 java.util.Collection.stream() 方法用集合創(chuàng)建流

          List list = Arrays.asList("a", "b", "c");// 創(chuàng)建一個(gè)順序流 Stream stream = list.stream();// 創(chuàng)建一個(gè)并行流 Stream parallelStream = list.parallelStream();
          登錄后復(fù)制

          2、使用 java.util.Arrays.stream(T[]array)方法用數(shù)組創(chuàng)建流

          int[] array={1,3,5,6,8};IntStream stream = Arrays.stream(array);
          登錄后復(fù)制

          3、使用 Stream的靜態(tài)方法:of()、iterate()、generate()

          Stream stream = Stream.of(1, 2, 3, 4, 5, 6);  Stream stream2 = Stream.iterate(0, (x) -> x + 3).limit(4);stream2.forEach(System.out::println);  Stream stream3 = Stream.generate(Math::random).limit(3);stream3.forEach(System.out::println);
          登錄后復(fù)制

          輸出結(jié)果:

          0 3 6 90.67961569092719940.19143142088542830.8116932592396652
          登錄后復(fù)制

          stream和 parallelStream的簡單區(qū)分:stream是順序流,由主線程按順序?qū)α鲌?zhí)行操作,而 parallelStream是并行流,內(nèi)部以多線程并行執(zhí)行的方式對流進(jìn)行操作,但前提是流中的數(shù)據(jù)處理沒有順序要求。例如篩選集合中的奇數(shù),兩者的處理不同之處:
          Java8中Stream詳細(xì)用法歸納
          如果流中的數(shù)據(jù)量足夠大,并行流可以加快處速度。

          除了直接創(chuàng)建并行流,還可以通過 parallel()把順序流轉(zhuǎn)換成并行流:

          Optional findFirst = list.stream().parallel().filter(x->x>6).findFirst();
          登錄后復(fù)制

          四、Stream API簡介

          Java8中Stream詳細(xì)用法歸納
          Java8中Stream詳細(xì)用法歸納

          先貼上幾個(gè)案例,水平高超的同學(xué)可以挑戰(zhàn)一下:從員工集合中篩選出salary大于8000的員工,并放置到新的集合里。統(tǒng)計(jì)員工的最高薪資、平均薪資、薪資之和。將員工按薪資從高到低排序,同樣薪資者年齡小者在前。將員工按性別分類,將員工按性別和地區(qū)分類,將員工按薪資是否高于8000分為兩部分。用傳統(tǒng)的迭代處理也不是很難,但代碼就顯得冗余了,跟Stream相比高下立判。
          登錄后復(fù)制

          前提:員工類

          static List personList = new ArrayList();private static void initPerson() {     personList.add(new Person("張三", 8, 3000));     personList.add(new Person("李四", 18, 5000));     personList.add(new Person("王五", 28, 7000));     personList.add(new Person("孫六", 38, 9000));}
          登錄后復(fù)制

          1、遍歷/匹配(foreach/find/match)

          Stream也是支持類似集合的遍歷和匹配元素的,只是 Stream中的元素是以 Optional類型存在的。Stream的遍歷、匹配非常簡單。

          // import已省略,請自行添加,后面代碼亦是   public class StreamTest {   public static void main(String[] args) {         List list = Arrays.asList(7, 6, 9, 3, 8, 2, 1);           // 遍歷輸出符合條件的元素         list.stream().filter(x -> x > 6).forEach(System.out::println);         // 匹配第一個(gè)         Optional findFirst = list.stream().filter(x -> x > 6).findFirst();         // 匹配任意(適用于并行流)         Optional findAny = list.parallelStream().filter(x -> x > 6).findAny();         // 是否包含符合特定條件的元素         boolean anyMatch = list.stream().anyMatch(x -> x < 6);         System.out.println("匹配第一個(gè)值:" + findFirst.get());         System.out.println("匹配任意一個(gè)值:" + findAny.get());         System.out.println("是否存在大于6的值:" + anyMatch);     }}
          登錄后復(fù)制

          2、按條件匹配filter

          Java8中Stream詳細(xì)用法歸納

          (1)篩選員工中已滿18周歲的人,并形成新的集合

          /**  * 篩選員工中已滿18周歲的人,并形成新的集合  * @思路  * List list = new ArrayList();  * for(Person person : personList) {  *     if(person.getAge() >= 18) {  *          list.add(person);  *     }  * }  */ private static void filter01() {     initPerson();     List collect = personList.stream().filter(x -> x.getAge()>=18).collect(Collectors.toList());     System.out.println(collect);}
          登錄后復(fù)制

          Java8中Stream詳細(xì)用法歸納
          (2)自定義條件匹配
          Java8中Stream詳細(xì)用法歸納

          3、聚合max、min、count

          Java8中Stream詳細(xì)用法歸納

          (1)獲取String集合中最長的元素

          /**  * 獲取String集合中最長的元素  * @思路  * List list = Arrays.asList("zhangsan", "lisi", "wangwu", "sunliu");  * String max = "";  * int length = 0;  * int tempLength = 0;  * for(String str : list) {  *     tempLength = str.length();  *     if(tempLength > length) {  *         length  = str.length();  *         max = str;  *      }  * }  * @return zhangsan  */ private static void test02() {     List list = Arrays.asList("zhangsan", "lisi", "wangwu", "sunliu");     Comparator comparator = Comparator.comparing(String::length);     Optional max = list.stream().max(comparator);     System.out.println(max);}
          登錄后復(fù)制

          Java8中Stream詳細(xì)用法歸納
          (2)獲取Integer集合中的最大值

          //獲取Integer集合中的最大值 private static void test05() {     List list = Arrays.asList(1, 17, 27, 7);     Optional max = list.stream().max(Integer::compareTo);     // 自定義排序     Optional max2 = list.stream().max(new Comparator() {         @Override         public int compare(Integer o1, Integer o2) {             return o1.compareTo(o2);         }     });     System.out.println(max2);}
          登錄后復(fù)制

          Java8中Stream詳細(xì)用法歸納

          //獲取員工中年齡最大的人 private static void test06() {     initPerson();     Comparator comparator = Comparator.comparingInt(Person::getAge);     Optional max = personList.stream().max(comparator);     System.out.println(max);}
          登錄后復(fù)制

          (3)獲取員工中年齡最大的人
          Java8中Stream詳細(xì)用法歸納
          4)計(jì)算integer集合中大于10的元素的個(gè)數(shù)
          Java8中Stream詳細(xì)用法歸納

          4、map與flatMap

          map:接收一個(gè)函數(shù)作為參數(shù),該函數(shù)會(huì)被應(yīng)用到每個(gè)元素上,并將其映射成一個(gè)新的元素。

          flatMap:接收一個(gè)函數(shù)作為參數(shù),將流中的每個(gè)值都換成另一個(gè)流,然后把所有流連接成一個(gè)流。

          Java8中Stream詳細(xì)用法歸納

          (1)字符串大寫
          Java8中Stream詳細(xì)用法歸納
          (2)整數(shù)數(shù)組每個(gè)元素+3

          /**  * 整數(shù)數(shù)組每個(gè)元素+3  * @思路  * List list = Arrays.asList(1, 17, 27, 7);    List list2 = new ArrayList();    for(Integer num : list) {       list2.add(num + 3);    }    @return [4, 20, 30, 10]  */ private static void test09() {     List list = Arrays.asList(1, 17, 27, 7);     List collect = list.stream().map(x -> x + 3).collect(Collectors.toList());     System.out.println(collect);}
          登錄后復(fù)制

          (3)公司效益好,每人漲2000

          /**  * 公司效益好,每人漲2000  *  */ private static void test10() {     initPerson();     List collect = personList.stream().map(x -> {         x.setAge(x.getSalary()+2000);         return x;     }).collect(Collectors.toList());     System.out.println(collect);}
          登錄后復(fù)制

          (4)將兩個(gè)字符數(shù)組合并成一個(gè)新的字符數(shù)組

          /**  * 將兩個(gè)字符數(shù)組合并成一個(gè)新的字符數(shù)組  *  */ private static void test11() {     String[] arr = {"z, h, a, n, g", "s, a, n"};     List list = Arrays.asList(arr);     System.out.println(list);     List collect = list.stream().flatMap(x -> {         String[] array = x.split(",");         Stream stream = Arrays.stream(array);         return stream;     }).collect(Collectors.toList());     System.out.println(collect);}
          登錄后復(fù)制

          (5)將兩個(gè)字符數(shù)組合并成一個(gè)新的字符數(shù)組

          /**  * 將兩個(gè)字符數(shù)組合并成一個(gè)新的字符數(shù)組  * @return [z,  h,  a,  n,  g, s,  a,  n]  */ private static void test11() {     String[] arr = {"z, h, a, n, g", "s, a, n"};     List list = Arrays.asList(arr);     List collect = list.stream().flatMap(x -> {         String[] array = x.split(",");         Stream stream = Arrays.stream(array);         return stream;     }).collect(Collectors.toList());     System.out.println(collect);}
          登錄后復(fù)制

          5、規(guī)約reduce

          歸約,也稱縮減,顧名思義,是把一個(gè)流縮減成一個(gè)值,能實(shí)現(xiàn)對集合求和、求乘積和求最值操作。
          Java8中Stream詳細(xì)用法歸納
          (1)求Integer集合的元素之和、乘積和最大值

          /**  * 求Integer集合的元素之和、乘積和最大值  *  */ private static void test13() {     List list = Arrays.asList(1, 2, 3, 4);     //求和     Optional reduce = list.stream().reduce((x,y) -> x+ y);     System.out.println("求和:"+reduce);     //求積     Optional reduce2 = list.stream().reduce((x,y) -> x * y);     System.out.println("求積:"+reduce2);     //求最大值     Optional reduce3 = list.stream().reduce((x,y) -> x>y?x:y);     System.out.println("求最大值:"+reduce3);}
          登錄后復(fù)制

          (2)求所有員工的工資之和和最高工資

          /*  * 求所有員工的工資之和和最高工資  */ private static void test14() {     initPerson();     Optional reduce = personList.stream().map(Person :: getSalary).reduce(Integer::sum);     Optional reduce2 = personList.stream().map(Person :: getSalary).reduce(Integer::max);     System.out.println("工資之和:"+reduce);     System.out.println("最高工資:"+reduce2);}
          登錄后復(fù)制

          6、收集(toList、toSet、toMap)

          取出大于18歲的員工轉(zhuǎn)為map

          /**  * 取出大于18歲的員工轉(zhuǎn)為map  *  */ private static void test15() {     initPerson();     Map collect = personList.stream().filter(x -> x.getAge() > 18).collect(Collectors.toMap(Person::getName, y -> y));     System.out.println(collect);}
          登錄后復(fù)制

          7、collect

          Collectors提供了一系列用于數(shù)據(jù)統(tǒng)計(jì)的靜態(tài)方法:

          計(jì)數(shù): count

          平均值: averagingInt、 averagingLong、 averagingDouble

          最值: maxBy、 minBy

          求和: summingInt、 summingLong、 summingDouble

          統(tǒng)計(jì)以上所有: summarizingInt、 summarizingLong、 summarizingDouble

          /**  * 統(tǒng)計(jì)員工人數(shù)、平均工資、工資總額、最高工資  */ private static void test01(){     //統(tǒng)計(jì)員工人數(shù)     Long count = personList.stream().collect(Collectors.counting());     //求平均工資     Double average = personList.stream().collect(Collectors.averagingDouble(Person::getSalary));     //求最高工資     Optional max = personList.stream().map(Person::getSalary).collect(Collectors.maxBy(Integer::compare));     //求工資之和     Integer sum = personList.stream().collect(Collectors.summingInt(Person::getSalary));     //一次性統(tǒng)計(jì)所有信息     DoubleSummaryStatistics collect = personList.stream().collect(Collectors.summarizingDouble(Person::getSalary));     System.out.println("統(tǒng)計(jì)員工人數(shù):"+count);     System.out.println("求平均工資:"+average);     System.out.println("求最高工資:"+max);     System.out.println("求工資之和:"+sum);     System.out.println("一次性統(tǒng)計(jì)所有信息:"+collect);}
          登錄后復(fù)制

          8、分組(partitioningBy/groupingBy)

          分區(qū):將stream按條件分為兩個(gè) Map,比如員工按薪資是否高于8000分為兩部分。

          分組:將集合分為多個(gè)Map,比如員工按性別分組。有單級分組和多級分組。
          Java8中Stream詳細(xì)用法歸納

          將員工按薪資是否高于8000分為兩部分;將員工按性別和地區(qū)分組

          public class StreamTest {   public static void main(String[] args) {     personList.add(new Person("zhangsan",25, 3000, "male", "tieling"));         personList.add(new Person("lisi",27, 5000, "male", "tieling"));         personList.add(new Person("wangwu",29, 7000, "female", "tieling"));         personList.add(new Person("sunliu",26, 3000, "female", "dalian"));         personList.add(new Person("yinqi",27, 5000, "male", "dalian"));         personList.add(new Person("guba",21, 7000, "female", "dalian"));       // 將員工按薪資是否高于8000分組         Map> part = personList.stream().collect(Collectors.partitioningBy(x -> x.getSalary() > 8000));         // 將員工按性別分組         Map> group = personList.stream().collect(Collectors.groupingBy(Person::getSex));         // 將員工先按性別分組,再按地區(qū)分組         Map>> group2 = personList.stream().collect(Collectors.groupingBy(Person::getSex, Collectors.groupingBy(Person::getArea)));         System.out.println("員工按薪資是否大于8000分組情況:" + part);         System.out.println("員工按性別分組情況:" + group);         System.out.println("員工按性別、地區(qū):" + group2);   }}
          登錄后復(fù)制

          9、連接joining

          joining可以將stream中的元素用特定的連接符(沒有的話,則直接連接)連接成一個(gè)字符串。
          Java8中Stream詳細(xì)用法歸納

          10、排序sorted

          將員工按工資由高到低(工資一樣則按年齡由大到?。┡判?/p>

          private static void test04(){     // 按工資升序排序(自然排序)     List newList = personList.stream().sorted(Comparator.comparing(Person::getSalary)).map(Person::getName)             .collect(Collectors.toList());     // 按工資倒序排序     List newList2 = personList.stream().sorted(Comparator.comparing(Person::getSalary).reversed())             .map(Person::getName).collect(Collectors.toList());     // 先按工資再按年齡升序排序     List newList3 = personList.stream()             .sorted(Comparator.comparing(Person::getSalary).thenComparing(Person::getAge)).map(Person::getName)             .collect(Collectors.toList());     // 先按工資再按年齡自定義排序(降序)     List newList4 = personList.stream().sorted((p1, p2) -> {         if (p1.getSalary() == p2.getSalary()) {             return p2.getAge() - p1.getAge();         } else {             return p2.getSalary() - p1.getSalary();         }     }).map(Person::getName).collect(Collectors.toList());       System.out.println("按工資升序排序:" + newList);     System.out.println("按工資降序排序:" + newList2);     System.out.println("先按工資再按年齡升序排序:" + newList3);     System.out.println("先按工資再按年齡自定義降序排序:" + newList4);}
          登錄后復(fù)制

          11、提取/組合

          流也可以進(jìn)行合并、去重、限制、跳過等操作。

          private static void test05(){     String[] arr1 = { "a", "b", "c", "d" };     String[] arr2 = { "d", "e", "f", "g" };     Stream stream1 = Stream.of(arr1);     Stream stream2 = Stream.of(arr2);     // concat:合并兩個(gè)流 distinct:去重     List newList = Stream.concat(stream1, stream2).distinct().collect(Collectors.toList());     // limit:限制從流中獲得前n個(gè)數(shù)據(jù)     List collect = Stream.iterate(1, x -> x + 2).limit(10).collect(Collectors.toList());     // skip:跳過前n個(gè)數(shù)據(jù)     List collect2 = Stream.iterate(1, x -> x + 2).skip(1).limit(5).collect(Collectors.toList());       System.out.println("流合并:" + newList);     System.out.println("limit:" + collect);     System.out.println("skip:" + collect2);}
          登錄后復(fù)制

          12、讀取文件的流操作

          Java8中Stream詳細(xì)用法歸納

          13、計(jì)算兩個(gè)list中的差集

          //計(jì)算兩個(gè)list中的差集 List reduce1 = allList.stream().filter(item -> !wList.contains(item)).collect(Collectors.toList());
          登錄后復(fù)制

          推薦學(xué)習(xí):《java視頻教程》

          贊(0)
          分享到: 更多 (0)
          網(wǎng)站地圖   滬ICP備18035694號-2    滬公網(wǎng)安備31011702889846號