複習Stream流，函數式介面，方法引用

来源:https://www.cnblogs.com/pzistart/archive/2022/12/30/17015819.html
-Advertisement-
Play Games

#增強for迴圈 增強for迴圈 (也稱for each迴圈) 是迭代器遍歷方法的一個“簡化版”，是JDK1.5以後出來的一個高級for迴圈，專門用來遍曆數組和集合。 普通for迴圈 int[] num = {1,2,3,4,5,6}; for(int i = 0 ; i<num.length ; ...


今天對這些內容進行了一個複習，以寫demo加做筆記的形式

stream能夠更加優雅的處理集合、數組等數據，讓我們寫出更加直觀、可讀性更高的數據處理代碼

創建steam流的方式

set、list能夠直接通過.stream()的形式創建steam流
而數組需要通過 Arrays.stream(arr); Stream.of(arr);
map需要通過entrySet()方法，先將map轉換成Set<Map.Entry<String, Integer>> set對象，再通過set.stream()的方式轉換

stream中的api比較多

/**
 * @author Pzi
 * @create 2022-12-30 13:22
 */
@SpringBootTest
@RunWith(SpringRunner.class)
public class Test2 {

    @Test
    public void test1() {
        List<Author> authors = S.getAuthors();
        authors
                .stream()
                .distinct()
                .filter(author -> {
                    // 滿足這個條件，那麼才會被篩選到繼續留在stream中
                    return author.getAge() < 18;
                })
                .forEach(author -> System.out.println(author.getAge()));
    }


    // 對雙列集合map的stream操作
    @Test
    public void test2() {
        Map<String, Integer> map = new HashMap<>();
        map.put("蠟筆小新", 19);
        map.put("黑子", 17);
        map.put("日向翔陽", 16);

        //entrySet是一個包含多個Entry的Set數據結構,Entry是key-val型的數據結構
        Set<Map.Entry<String, Integer>> entries = map.entrySet();

        entries.stream()
                .filter(entry -> {
                    return entry.getValue() > 17;
                })
                .forEach(entry -> {
                    System.out.println(entry);
                });
    }


    // stream的map操作，提取stream中對象的屬性，或者計算
    @Test
    public void test3() {
        List<Author> authors = S.getAuthors();
        authors
                .stream()
                .map(author -> author.getName())
                .forEach(name -> System.out.println(name));
        System.out.println(1);

        authors
                .stream()
                .map(author -> author.getAge())
                .map(age -> age + 10)
                .forEach(age -> System.out.println(age));
    }

    // steam的sorted操作
    @Test
    public void test4() {
        List<Author> authors = S.getAuthors();
        authors
                .stream()
                .distinct()
                .sorted(((o1, o2) -> o2.getAge() - o1.getAge()))
                .skip(1)
                .forEach(author -> System.out.println(author.getName() + " " + author.getAge()));
    }

    // flapMap的使用，重新組裝，改變stream流中存放的對象
    @Test
    public void test5() {
        //        列印所有書籍的名字。要求對重覆的元素進行去重。
        List<Author> authors = S.getAuthors();

        authors.stream()
                .flatMap(author -> author.getBooks().stream())
                .distinct()
                .forEach(book -> System.out.println(book.getName()));

        authors.stream()
                // 將以authors為對象的stream流 組裝成 以book為對象的strem流
                .flatMap(author -> author.getBooks().stream())
                .distinct()
                // 將每個book中的category轉換成數組，然後將[x1,x2]代表分類的數組轉換成stream流，然後使用flapMap將該數組stream流組裝成以x1,x2...為對象的stream流
                // 將以book為對象的strem流 組裝成 以category為對象的stream流
                .flatMap(book -> Arrays.stream(book.getCategory().split(",")))
                .distinct()
                .forEach(category -> System.out.println(category));
    }

    // 數組轉換成stream流
    @Test
    public void test6() {
        Integer[] arr = {1, 2, 3, 4, 5};
        Stream<Integer> stream = Arrays.stream(arr);
        stream
                .filter(integer -> integer > 3)
                .forEach(integer -> System.out.println(integer));
    }

    @Test
    public void test7() {
//        列印這些作家的所出書籍的數目，註意刪除重覆元素。
        List<Author> authors = S.getAuthors();
        long count = authors
                .stream()
                .flatMap(author -> author.getBooks().stream())
                .distinct()
                .count();
        System.out.println(count);
    }

    // max() min()
    @Test
    public void test8() {
//	分別獲取這些作家的所出書籍的最高分和最低分並列印。
        List<Author> authors = S.getAuthors();
        Optional<Integer> max = authors.stream()
                .flatMap(author -> author.getBooks().stream())
                .map(book -> book.getScore())
                .max((score1, score2) -> score1 - score2);


        Optional<Integer> min = authors.stream()
                .flatMap(author -> author.getBooks().stream())
                .map(book -> book.getScore())
                .min((score1, score2) -> score1 - score2);
        System.out.println(max.get());
        System.out.println(min.get());

    }

    // stream 的 collect()
    @Test
    public void test9() {
        // 獲取所有作者名字
        List<Author> authors = S.getAuthors();
        Set<String> collect = authors.stream()
                .map(author -> author.getName())
                .collect(Collectors.toSet());
        System.out.println(collect);

        //獲取一個所有書名的Set集合。
        Set<String> collect1 = authors.stream()
                .flatMap(author -> author.getBooks().stream())
                .map(book -> book.getName())
                .collect(Collectors.toSet());
        System.out.println(collect1);

        //	獲取一個Map集合，map的key為作者名，value為List<Book>
        Map<String, List<Book>> collect2 = authors.stream()
                .distinct()
                .collect(Collectors.toMap(author -> author.getName(), author -> author.getBooks()));

        System.out.println(collect2);

    }

    // anyMatch
    @Test
    public void test10() {
        List<Author> authors = S.getAuthors();
        boolean b = authors.stream()
                .anyMatch(author -> author.getAge() > 29);
        System.out.println(b);
    }

    // allMatch
    @Test
    public void test11() {
        List<Author> authors = S.getAuthors();
        boolean b = authors.stream()
                .allMatch(author -> author.getAge() > 18);
        System.out.println(b);
    }

    // findFirst
    @Test
    public void test12() {
        List<Author> authors = S.getAuthors();
        Optional<Author> first = authors.stream()
                .sorted(((o1, o2) -> o1.getAge() - o2.getAge()))
                .findFirst();
        first.ifPresent(author -> System.out.println(author));
    }

    // reduce() 的使用
    @Test
    public void test13() {
        //        使用reduce求所有作者年齡的和
        List<Author> authors = S.getAuthors();
        Integer sum = authors.stream()
                .distinct()
                .map(author -> author.getAge())
                .reduce(0, (result, element) -> result + element);
//                .reduce(0, (result, element) -> result + element);
        System.out.println(sum);
    }

    @Test
    public void test14() {
        //        使用reduce求所有作者中年齡的最小值
        List<Author> authors = S.getAuthors();
        Integer minAge = authors.stream()
                .map(author -> author.getAge())
                .reduce(Integer.MAX_VALUE, (res, ele) -> res > ele ? ele : res);
        System.out.println(minAge);
    }

    // 沒有初始值的reduce()使用
    @Test
    public void test15() {
        List<Author> authors = S.getAuthors();
        Optional<Integer> age = authors.stream()
                .map(author -> author.getAge())
                .reduce((res, ele) -> res > ele ? ele : res);
        System.out.println(age.get());
    }


    // Optional對象的封裝，orElseGet的使用
    @Test
    public void test16() {
        Optional<Author> authorOptional = Optional.ofNullable(null);
        Author author1 = authorOptional.orElseGet(() -> new Author(1l, "1", 1, "1", null));
        System.out.println(author1);
//        authorOptional.ifPresent(author -> System.out.println(author.getName()));
    }

    @Test
    public void test17() {
        Optional<Author> authorOptional = Optional.ofNullable(null);
        try {
            Author author = authorOptional.orElseThrow((Supplier<Throwable>) () -> new RuntimeException("exception"));
            System.out.println(author.getName());
        } catch (Throwable throwable) {
            throwable.printStackTrace();
        }
    }

    // Optional的filter()方法
    // ifPresent()可以安全消費Optional中包裝的對象
    @Test
    public void test18() {
        Optional<Author> optionalAuthor = Optional.ofNullable(S.getAuthors().get(0));
        optionalAuthor
                .filter(author -> author.getAge() > 14)
                .ifPresent(author -> System.out.println(author));
    }


    // Optional的isPresent()方法，用來判斷該Optional是否包裝了對象
    @Test
    public void test19() {
        Optional<Author> optionalAuthor = Optional.ofNullable(S.getAuthors().get(0));
        boolean present = optionalAuthor.isPresent();
        if (present) {
            System.out.println(optionalAuthor.get().getName());
        }
    }

    //  Optional的map()，將一個 Optional 轉換成另一個 Optional
    @Test
    public void test20() {
        Optional<Author> optionalAuthor = Optional.ofNullable(S.getAuthors().get(0));
        optionalAuthor.ifPresent(author -> System.out.println(author.getBooks()));
        Optional<List<Book>> books = optionalAuthor.map(author -> author.getBooks());
        books.ifPresent(books1 -> System.out.println(books.get()));
    }

    // 類的靜態方法
    @Test
    public void test21() {
        List<Author> authors = S.getAuthors();
        authors.stream()
                .map(author -> author.getAge())
                .map(integer -> String.valueOf(integer));
        // lambda方法體中只有一行代碼
//                .map(String::valueOf);
    }

    // 對象的實例方法
    @Test
    public void test22() {
        List<Author> authors = S.getAuthors();
        Stream<Author> authorStream = authors.stream();
        StringBuilder sb = new StringBuilder();
        authorStream.map(author -> author.getName())
                // lambda方法體中只有一行代碼，且將參數全部按照順序傳入這個重寫方法中
                .forEach(str -> sb.append(str));
    }


    // 介面中只有一個抽象方法稱為函數式介面
    // 方法引用的條件是：lambda方法體中只有一行方法

    // 構造器的方法引用
    @Test
    public void test23() {
        List<Author> authors = S.getAuthors();
        authors.stream()
                .map(Author::getName)
                .map(StringBuilder::new)
                .map(stringBuilder -> stringBuilder.append("abc"))
                .forEach(System.out::println);
    }


    // steam提供的處理基本數據類型，避免頻繁的自動拆/裝箱，從而達到省時，提高性能
    @Test
    public void test24() {
        List<Author> authors = S.getAuthors();
        authors.stream()
                .map(author -> author.getAge())
                .map(age -> age + 10)
                .filter(age -> age > 18)
                .map(age -> age + 2)
                .forEach(System.out::println);


        authors.stream()
                .mapToInt(author -> author.getAge())
                .map(age -> age + 10)
                .filter(age -> age > 18)
                .map(age -> age + 2)
                .forEach(System.out::println);
    }

    @Test
    public void test25() {
        List<Author> authors = S.getAuthors();
        authors.stream()
                .parallel()
                .map(author -> author.getAge())
                .peek(integer -> System.out.println(integer+" "+Thread.currentThread().getName()))
                .reduce(new BinaryOperator<Integer>() {
                    @Override
                    public Integer apply(Integer result, Integer ele) {
                        return result + ele;
                    }
                }).ifPresent(sum -> System.out.println(sum));
    }


}

lambda表達式

lambda表達式只關心 形參列表 和 方法體
用在重寫抽象方法的時候，一般都是採用lambda表達式的方式來重寫

函數式介面

函數式介面：介面中只有一個抽象方法，就稱之為函數式介面。在Java中Consumer，Funciton，Supplier

方法引用

方法引用：當lambda表達式的方法體中只有一行代碼，並且符合一些規則，就可以將該行代碼轉換成方法引用的形式
可以直接使用idea的提示自動轉換
這隻是一個語法糖，能看懂代碼就行，不要過於糾結


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 工業數據分析為什麼要用FusionInsight MRS IoTDB？
    摘要：MRS IoTDB，它是華為FusionInsight MRS大數據套件中的時序資料庫產品，在深度參與Apache IoTDB社區開源版的基礎上推出的高性能企業級時序資料庫產品。 本文分享自華為雲社區《工業數據分析為什麼要用FusionInsight MRS IoTDB？》，作者：高深廣 。 ...
  • CloudCanal對Online DDL 工具 GH-OST 和 PT-OSC 的支持
    簡介 CloudCanal 實現了對 Online DDL 工具如 GH-OST 和 PT-OSC 的支持，保證了對端實時同步源端的 Online DDL 操作。 本文以 MySQL -> MySQL 同步鏈路使用 GH-OST 為例，介紹 CloudCanal 是如何支持實時同步 GH-OST 產 ...
  • 大數據 - DWS層 業務實現
    統計主題 需求指標【ADS】輸出方式計算來源來源層級 訪客【DWS】pv可視化大屏page_log 直接可求dwd UV（DAU）可視化大屏需要用 page_log 過濾去重dwm UJ 跳出率可視化大屏需要通過 page_log 行為判斷dwm 進入頁面數可視化大屏需要識別開始訪問標識dwd 連續 ...
  • Ng-Matero v15 正式發佈
    前言 Angular 按照既定的發版計劃在 11 月中旬發佈了 v15 版本。推遲了一個月（幾乎每個版本都是這個節奏😳），Ng-Matero 也終於更新到了 v15。其實 Ng-Matero 本身的更新非常簡單，但是同步維護的 Material Extensions 這個庫要先於 Ng-Mater ...
  • go-淺學設計模式隨記
    談起消息隊列，內心還是會有些波瀾。 消息隊列、緩存、分庫分表是高併發解決方案三劍客，而消息隊列是我最喜歡，也是思考最多的技術。我想按照下麵的四個階段分享我與消息隊列的故事，同時也是對我技術成長經歷的回顧。 ...
  • 淺談C語言編譯原理
    C語言 我們在學習電腦學科時，往往最先接觸到的編程語言是C，它是所有語言中，最接近底層的高級語言之一，因而它具有執行速度快的優點。但它又具有開發周期長和對於經驗不足的開發者極容易犯錯的缺點。C語言應用範圍廣泛，你幾乎可以在任何場景中看到它的影子。 C語言編譯原理 一個編寫好的C代碼經過編譯成可執行 ...
  • Windows下jdk安裝與卸載-超詳細的圖文教程
    jdk安裝 下載jdk 由於現在主流就是jdk1.8，所以這裡就下載jdk1.8進行演示。官方下載地址：https://www.oracle.com/java/technologies/downloads/#java8-windows。 官方下載需要註冊oracle賬號，國內下載有可能速度慢，若不想 ...
  • LeetCode-400. 第N位數字
    題目來源 400. 第 N 位數字 題目詳情 給你一個整數 n ，請你在無限的整數序列 [1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, ...] 中找出並返回第 n 位上的數字。 示例 1： 輸入： n = 3 輸出： 3 示例 2： 輸入： n = 11 輸出： 0 解釋： ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類