java 合并流_Java Stream 流实现合并操作示例
本文實例講述了Java Stream 流實現合并操作。分享給大家供大家參考,具體如下:
1. 前言
Java Stream Api提供了很多有用的 Api 讓我們很方便將集合或者多個同類型的元素轉換為流進行操作。今天我們來看看如何合并 Stream 流。
2. Stream 流的合并
Stream 流合并的前提是元素的類型能夠一致。
2.1 concat
最簡單合并流的方法是通過 Stream.concat() 靜態方法:
Stream stream = Stream.of(1, 2, 3);
Stream another = Stream.of(4, 5, 6);
Stream concat = Stream.concat(stream, another);
List collect = concat.collect(Collectors.toList());
List expected = Lists.list(1, 2, 3, 4, 5, 6);
Assertions.assertIterableEquals(expected, collect);
這種合并是將兩個流一前一后進行拼接:
2.2 多個流的合并
多個流的合并我們也可以使用上面的方式進行“套娃操作”:
Stream.concat(Stream.concat(stream, another), more);
你可以一層一層繼續套下去,如果需要合并的流多了,看上去不是很清晰。
我之前介紹過一個Stream 的 flatmap 操作,它的大致流程可以參考里面的這一張圖:
因此我們可以通過 flatmap 進行實現合并多個流:
Stream stream = Stream.of(1, 2, 3);
Stream another = Stream.of(4, 5, 6);
Stream third = Stream.of(7, 8, 9);
Stream more = Stream.of(0);
Stream concat = Stream.of(stream,another,third,more).
flatMap(integerStream -> integerStream);
List collect = concat.collect(Collectors.toList());
List expected = Lists.list(1, 2, 3, 4, 5, 6, 7, 8, 9, 0);
Assertions.assertIterableEquals(expected, collect);
這種方式是先將多個流作為元素生成一個類型為 Stream> 的流,然后進行 flatmap 平鋪操作合并。
2.3 第三方庫
有很多第三方的強化庫 StreamEx 、Jooλ 都可以進行合并操作。另外反應式編程庫 Reactor 3 也可以將 Stream 流合并為反應流,在某些場景下可能會有用。這里演示一下:
List block = Flux.fromStream(stream)
.mergeWith(Flux.fromStream(another))
.collectList()
.block();
3. 總結
如果你經常使用 Java Stream Api ,合并 Stream 流是經常遇到的操作。
希望本文所述對大家java程序設計有所幫助。
總結
以上是生活随笔為你收集整理的java 合并流_Java Stream 流实现合并操作示例的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 二维教组A[12][18]采用列优先的存
- 下一篇: android纹理缓存,Android