Java Stream 流實現合併操作示例
阿新 • • 發佈:2020-05-21
本文例項講述了Java Stream 流實現合併操作。分享給大家供大家參考,具體如下:
1. 前言
Java Stream Api 提供了很多有用的 Api 讓我們很方便將集合或者多個同類型的元素轉換為流進行操作。今天我們來看看如何合併 Stream 流。
2. Stream 流的合併
Stream 流合併的前提是元素的型別能夠一致。
2.1 concat
最簡單合併流的方法是通過 Stream.concat() 靜態方法:
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,3,4,6); Assertions.assertIterableEquals(expected,collect);
這種合併是將兩個流一前一後進行拼接:
2.2 多個流的合併
多個流的合併我們也可以使用上面的方式進行“套娃操作”:
Stream.concat(Stream.concat(stream,another),more);
你可以一層一層繼續套下去,如果需要合併的流多了,看上去不是很清晰。
我之前介紹過一個Stream 的 flatmap 操作 ,它的大致流程可以參考裡面的這一張圖:
因此我們可以通過 flatmap 進行實現合併多個流:
Stream<Integer> stream = Stream.of(1,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,6,7,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. 總結
如果你經常使用 Java Stream Api ,合併 Stream 流是經常遇到的操作。
更多關於java演算法相關內容感興趣的讀者可檢視本站專題:《Java檔案與目錄操作技巧彙總》、《Java資料結構與演算法教程》、《Java操作DOM節點技巧總結》和《Java快取操作技巧彙總》
希望本文所述對大家java程式設計有所幫助。