Java Stream 流實現(xiàn)合并操作示例
本文實例講述了Java Stream 流實現(xiàn)合并操作。分享給大家供大家參考,具體如下:
1. 前言
Java Stream Api 提供了很多有用的 Api 讓我們很方便將集合或者多個同類型的元素轉(zhuǎn)換為流進行操作。今天我們來看看如何合并 Stream 流。
2. Stream 流的合并
Stream 流合并的前提是元素的類型能夠一致。
2.1 concat
最簡單合并流的方法是通過 Stream.concat() 靜態(tài)方法:
Stream<Integer> stream = Stream.of(1, 2, 3); Stream<Integer> another = Stream.of(4, 5, 6); Stream<Integer> concat = Stream.concat(stream, another); List<Integer> collect = concat.collect(Collectors.toList()); List<Integer> expected = Lists.list(1, 2, 3, 4, 5, 6); Assertions.assertIterableEquals(expected, collect);
這種合并是將兩個流一前一后進行拼接:

2.2 多個流的合并
多個流的合并我們也可以使用上面的方式進行“套娃操作”:
Stream.concat(Stream.concat(stream, another), more);
你可以一層一層繼續(xù)套下去,如果需要合并的流多了,看上去不是很清晰。
我之前介紹過一個Stream 的 flatmap 操作 ,它的大致流程可以參考里面的這一張圖:

因此我們可以通過 flatmap 進行實現(xiàn)合并多個流:
Stream<Integer> stream = Stream.of(1, 2, 3); Stream<Integer> another = Stream.of(4, 5, 6); Stream<Integer> third = Stream.of(7, 8, 9); Stream<Integer> more = Stream.of(0); Stream<Integer> concat = Stream.of(stream,another,third,more). flatMap(integerStream -> integerStream); List<Integer> collect = concat.collect(Collectors.toList()); List<Integer> expected = Lists.list(1, 2, 3, 4, 5, 6, 7, 8, 9, 0); Assertions.assertIterableEquals(expected, collect);
這種方式是先將多個流作為元素生成一個類型為 Stream<Stream<T>> 的流,然后進行 flatmap 平鋪操作合并。
2.3 第三方庫
有很多第三方的強化庫 StreamEx 、Jooλ 都可以進行合并操作。另外反應式編程庫 Reactor 3 也可以將 Stream 流合并為反應流,在某些場景下可能會有用。這里演示一下:
List<Integer> block = Flux.fromStream(stream)
.mergeWith(Flux.fromStream(another))
.collectList()
.block();
3. 總結(jié)
如果你經(jīng)常使用 Java Stream Api ,合并 Stream 流是經(jīng)常遇到的操作。
更多關于java算法相關內(nèi)容感興趣的讀者可查看本站專題:《Java文件與目錄操作技巧匯總》、《Java數(shù)據(jù)結(jié)構(gòu)與算法教程》、《Java操作DOM節(jié)點技巧總結(jié)》和《Java緩存操作技巧匯總》
希望本文所述對大家java程序設計有所幫助。
相關文章
Java 進階使用 Lambda 表達式實現(xiàn)超強的排序功能
今天要說的是第二種排序方式,在內(nèi)存中實現(xiàn)數(shù)據(jù)排序。這篇文章主要介紹了Java 進階使用 Lambda 表達式實現(xiàn)超強的排序功能,需要的朋友可以參考下2021-11-11
java面向?qū)ο缶幊讨匾拍罾^承和多態(tài)示例解析
這篇文章主要為大家介紹了java面向?qū)ο缶幊痰膬蓚€重要概念繼承和多態(tài)示例解析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-05-05
java數(shù)據(jù)結(jié)構(gòu)之搜索二叉樹
這篇文章主要為大家詳細介紹了java數(shù)據(jù)結(jié)構(gòu)之搜索二叉樹,文中示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下2022-01-01
使用list stream:對List中的對象先進行排序再獲取前n個對象
這篇文章主要介紹了使用list stream:對List中的對象先進行排序再獲取前n個對象,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2021-09-09

