Java中stream處理中map與flatMap的比較和使用案例
前言
使用Java8的新特性Stream流式處理,可以提高對于集合的一些操作效率,再配合lambda表達式,可以極致的簡化代碼,尤其還有并行流這個東東,可以去 了解一下,在一些場合還是可以提高效率的,而且編碼起來也不費事。
并且流式處理的核心就是一個淺拷貝和引用管道,其內(nèi)部實現(xiàn)了一個引用管道ReferencePipeline, 他把需要處理的數(shù)據(jù)的引用拷貝了一份,然后處理數(shù)據(jù),最后收集結(jié)果也是將這些引用放到了另一個集合中。
今天要講的就是stream處理中的map和flatMap這倆個的比較和使用
共同點和區(qū)別
首先看一下源代碼
<R> Stream<R> map(Function<? super T, ? extends R> mapper); <R> Stream<R> flatMap(Function<? super T, ? extends Stream<? extends R>> mapper);
共同點
- 都是依賴stream進行轉(zhuǎn)換,結(jié)合lambda的入?yún)⒑头祷刂?,將一個類型依據(jù)程序邏輯轉(zhuǎn)換成另一種類型。
- 最后結(jié)果返回都還是一個流,還可以對其進行繼續(xù)的流式處理或者進行收集。
區(qū)別
- 方法參數(shù)不同,第一個參數(shù)是一樣的,但是第二個不一樣,對于map第二個參數(shù)沒啥要求,但是使用flatMap時,第二個參數(shù)還得用流來接收。
- 所以flatMap多用于多對多,一對多,也就是map是將一個數(shù)據(jù)流中的一個數(shù)據(jù)節(jié)點,映射成另外一個數(shù)據(jù)節(jié)點,而flatMap是將一個數(shù)據(jù)流中的一個數(shù)據(jù)節(jié)點映射成另外一個數(shù)據(jù)流,這個另外的數(shù)據(jù)流可以是一個數(shù)據(jù)節(jié)點也可以是多個數(shù)據(jù)節(jié)點。
- flatmap既可以單一轉(zhuǎn)換也可以一對多/多對多轉(zhuǎn)換,flatmap要求返回Observable,因此可以再內(nèi)部進行from/just的再次事件分發(fā),一一取出單一對象(轉(zhuǎn)換對象的能力不同)
使用案例
比如我們使用map將一個per對象映射成一個字符串對象
static class Per {
public String name;
public int age;
public Per(String name, int age) {
this.name = name;
this.age = age;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public int getAge() {
return age;
}
public void setAge(int age) {
this.age = age;
}
@Override
public String toString() {
return "Per{" +
"name='" + name + '\'' +
", age=" + age +
'}';
}
}
public static void main(String[] args) {
List<Per> list = new ArrayList<>();
list.add(new Per("listen", 22));
list.add(new Per("bike", 24));
list.add(new Per("milk", 27));
List<String> collect = list.stream().map(Per::toString).collect(Collectors.toList());
System.out.println(list);
System.out.println("---");
System.out.println(collect);
}
一對一可以實現(xiàn),那我們該需求,假設(shè)一個per人有多個孩子,我們想獲取這多個孩子,使用map可以實現(xiàn)嗎?比如下面代碼。
static class Child {
public String name;
public int age;
public Child(String name, int age) {
this.name = name;
this.age = age;
}
@Override
public String toString() {
return "Child{" +
"name='" + name + '\'' +
", age=" + age +
'}';
}
}
static class Per {
public String name;
public int age;
public Child[] Children;
public Per(String name, int age) {
this.name = name;
this.age = age;
}
public Child[] getChildren() {
return Children;
}
public void setChildren(Child[] children) {
Children = children;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public int getAge() {
return age;
}
public void setAge(int age) {
this.age = age;
}
@Override
public String toString() {
return "Per{" +
"name='" + name + '\'' +
", age=" + age +
'}';
}
}
這個時候注意這個孩子是多個,我們用的是數(shù)組存儲。如果此時我們還用map,那么只能接受每個per的孩子數(shù)組,不能和我們所愿接受每個孩子。
public static void main(String[] args) {
List<Per> list = new ArrayList<>();
Per per1 = new Per("Listen", 22);
per1.setChildren(new Child[] {new Child("a", 1), new Child("b", 2)});
Per per2 = new Per("Milk", 26);
per2.setChildren(new Child[] {new Child("c", 1), new Child("d", 2)});
list.add(per1);
list.add(per2);
List<Child[]> collect = list.stream().map(Per::getChildren).collect(Collectors.toList());
collect.forEach(item -> System.out.println(Arrays.toString(item)));
}
而使用flatMap就可以實現(xiàn)。
public static void main(String[] args) {
List<Per> list = new ArrayList<>();
Per per1 = new Per("Listen", 22);
per1.setChildren(new Child[] {new Child("a", 1), new Child("b", 2)});
Per per2 = new Per("Milk", 26);
per2.setChildren(new Child[] {new Child("c", 1), new Child("d", 2)});
list.add(per1);
list.add(per2);
List<Child> collect = list.stream().flatMap(item -> Arrays.stream(item.getChildren())).collect(Collectors.toList());
System.out.println(collect);
}
到此這篇關(guān)于Java中stream處理中map與flatMap的比較和使用案例的文章就介紹到這了,更多相關(guān)Java map與flatMap內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Spring Boot集成MyBatis訪問數(shù)據(jù)庫的方法
這篇文章主要介紹了Spring Boot集成MyBatis訪問數(shù)據(jù)庫的方法,需要的朋友可以參考下2017-04-04
Spring Boot Mail QQ企業(yè)郵箱無法連接解決方案
這篇文章主要介紹了Spring Boot Mail QQ企業(yè)郵箱無法連接解決方案,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2020-09-09
springboot關(guān)于容器啟動事件總結(jié)
在本篇文章里小編給大家整理的是一篇關(guān)于springboot容器啟動事件相關(guān)知識點,需要的朋友們學(xué)習(xí)下。2019-10-10
Java的super關(guān)鍵字與instanceof運算符使用方法
這篇文章主要介紹了Java的super關(guān)鍵字與instanceof運算符使用方法,是Java入門學(xué)習(xí)中的基礎(chǔ)知識,需要的朋友可以參考下2015-09-09
關(guān)于String.format()格式化輸出方式
String.format()是Java的格式化輸出方法,支持多種數(shù)據(jù)類型和格式化選項,它在格式化和拼接字符串時具有較高的靈活性,但效率相對較低,特別是在處理大量數(shù)據(jù)時,在實際編程中,應(yīng)根據(jù)具體需求選擇合適的字符串拼接方式2024-12-12
使用filebeat收集并解析springboot日志過程示例
這篇文章主要為大家介紹了使用filebeat收集并解析springboot日志實現(xiàn)過程示例,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-08-08

