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);

这种合并是将两个流一前一后进行拼接:

9b6e34e51c49ff070a3a3e3b76ce4b83.png

2.2 多个流的合并

多个流的合并我们也可以使用上面的方式进行“套娃操作”:

Stream.concat(Stream.concat(stream, another), more);

你可以一层一层继续套下去,如果需要合并的流多了,看上去不是很清晰。

我之前介绍过一个Stream 的 flatmap 操作,它的大致流程可以参考里面的这一张图:

78065457a60ca9530187ec0e3e27cebc.png

因此我们可以通过 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程序设计有所帮助。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/575806.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

java 去掉 t_java中的“\t”

对于初学者来说,java中的"\t"和空格总是让人迷惑,其实很简单,通过一个例子就能很快明白!比如说打印九九乘法表!先来看用空格的效果!1 package cn.edu.nwpu.java;23 public class MultiplicationT…

如何检测文件中的违禁词和小于规定大小的文件?

1 <?php2 foreach(array(a.txt,b.txt,c.txt) as $v){3 4 $file./article/.$v;5 6 if(filesize($file)<10){7 8 echo $v."文件小于10字节&#xff0c;已经被删除"."<br/>";9 unlink($file); 10 continue;} 11 $confile_get_contents(…

java excel 操作方式_Java读写Excel基本操作

Apache POI是Apache软件基金会的开放源码函式库&#xff0c;POI提供API给Java程式对Microsoft Office格式档案读和写的功能。接口&#xff1a;HSSF &#xff0d; Microsoft ExcelXSSF &#xff0d; Microsoft Excel OOXML(07以上版本)HWPF &#xff0d; Microsoft WordHSLF &am…

C语言根据日期(年,月,日)判断星期几(使用基姆拉尔森计算公式)

C语言根据日期判断星期几&#xff08;使用基姆拉尔森计算公式&#xff09; 算法如下&#xff1a; 基姆拉尔森计算公式W (d2*m3*(m1)/5yy/4-y/100y/400) mod 7 在公式中d表示日期中的日数&#xff0c;m表示月份数&#xff0c;y表示年数。 注意&#xff1a;在公式中有个与其他公式…

java service层 事务_Java高并发秒时啊API之Service层1

---2-1 使用Spring托管Service依赖理论----------------------------spring ioc优势(工厂模式):1.对象创建统一托管2.规范的生命周期管理3.灵活的依赖注入4.一致的获取对象Spring IOC 功能的理解DAO依赖Service依赖最终形成一致访问接口&#xff1b;随意访问依赖对象Spring IOC…

【网摘阅读】舒迅:产品经理必读的九步法

前几天读到一篇文章&#xff0c;觉得内容很好&#xff0c;推荐一下。本文摘自 http://www.huangshaofeng.com/422 产品设计“九步法” 第一步&#xff1a;产品满足用户的哪一个核心需求&#xff1f; 第二步&#xff1a;与同类产品相比你的独特性什么&#xff1f; 第三步&…

zoj 3720

为什么注释掉的地方是错的&#xff1f; 自己的代码好糟烂..... 直接枚举点 判是否在多边形内 加起来求概率 求面积的时候代码写搓了.... 比不过别人两行的代码 而且到现在还找不到错..... #include <iostream> #include <fstream> #include <cstri…

void在java中是什么意思_java中void什么意思

在java中&#xff0c;void代表的意思是“空”&#xff0c;即“什么都不返回”&#xff0c;在方法申明的时候表示该方法没有返回值。void对应着一个Void类&#xff0c;Void类是用final修饰的&#xff0c;是一个不可实例化的占位符类。之前&#xff0c;在学C的数据类型的时候发现…

《设计模式》-模板模式

玩物丧志啊&#xff01;&#xff01;&#xff01;最近总想着玩&#xff0c;休息&#xff0c;结果又耽误了半个月。。唉&#xff01; 惭愧啊。 今天是设计模式的倒数第二个了。。 虽然前面的 忘得差不多了。不过等看完了 要进行总复习&#xff0c;再复习&#xff0c;再回归&…

java 多个方法_java中的多个main()方法

它不会导致错误.只是因为你初始化一个对象,并不意味着main方法被执行. Java只会最初调用传递给它的类的main方法> java TestClass但是,做一些事情&#xff1a;public class TestClass{public static void main (String[] args){TestClass foo new TestClass();foo.main(arg…

一看就会之—利用IIS服务发布网站(实践篇)上

转自&#xff1a;http://blog.csdn.net/zwk626542417/article/details/9796259 概述 IIS全称为互联网信息服务&#xff0c;是由微软公司提供的基于运行MicrosoftWindows的互联网基本服务&#xff0c;今天我们主要来看下如何用win7系统自带的IIS服务来发布我们开发的一个简单的…

java md5 算法实现_Java 实现Md5算法

package other;import java.security.MessageDigest;import java.security.NoSuchAlgorithmException;/** MD5 算法*/public class MD5 {// 全局数组private final static String[] strDigits { "0", "1", "2", "3", "4", …

xp变量 java_winxp系统设置java环境变量的详细教程

我们都知道想要进行java的程序编辑&#xff0c;就要首先在电脑上设置环境变量&#xff0c;这样才能够运行java程序&#xff0c;下面一起看看xp系统的电脑如何设置java变量。1、设置环境变量之前&#xff0c;我们肯定首先需要安装java&#xff0c;首先&#xff0c;找到你安装jav…

Context 之我见

Context这个单词在程序开发中屡见不鲜&#xff0c;我记得以前在博客中写过一些关于这个词语的自我解释&#xff0c;但是我这个人有一个毛病就是健忘&#xff0c;如果不将自己的想法写下&#xff0c;不出十分钟&#xff0c;就被我抛到九霄云外。 真我现在还有点想法&#xff0c;…

java按钮随机移动_java – 使按钮移动触摸我们触摸的确切位置

我创建了一个应用程序,其中有一个按钮在触摸它时移动.现在对于onTouch,我实现了一个不同的类.有两个类,一个是主要的CircleMActivity.java,另一个是onTouch.现在应用程序运行正常,但有一个问题.当我点击按钮并移动它时它正在移动,但按钮和屏幕触摸之间有一个间隙.我想要的是将它…

MySQL性能优化的最佳经验

今天&#xff0c;数据库的操作越来越成为整个应用的性能瓶颈了&#xff0c;这点对于Web应用尤其明显。关于数据库的性能&#xff0c;这并不只是DBA才需要担心的事&#xff0c;而这更是我们程序员需要去关注的事情。当我们去设计数据库表结构&#xff0c;对操作数据库时&#xf…

jspstudy mysql_使用JspStudy集成环境快速部署jsp项目

标签&#xff1a;1. 安装jdk本人网盘资源&#xff1a;https://yunpan.cn/ckZLNbqxkDYYe (提取码&#xff1a;b5e8)去jdk官网下载最新的jdk: http://www.oracle.com/technetwork/java/javase/downloads/jdk-7u2-download-1377129.html2. 配置环境变量&#xff1a;1) 系统变量→新…

java听课笔记(六)

面向对象 对象的概念 什么是对象 一切客观存在的事物都是对象 对象组成 属性&#xff0c;方法 类 描述同类对象的共有的属性和方法 类是创建对象的模板 全局变量 实例变量 有默认值&#xff0c;引用类型是null&#xff0c;基本 局部变量可以暂时屏蔽全局变量 局部变量没有默认值…

IOS7的蛋疼各种收集

------------------ ios7基于viewController隐藏状态条:通过ViewController重载方法返回枚举值的方法来控制状态栏的隐藏和样式。首先&#xff0c;需要在Info.plist配置文件中&#xff0c;增加键&#xff1a;UIViewControllerBasedStatusBarAppearance&#xff0c;并设置为YES&…

mysql sjis 校对乱码_MySQL字符集乱码及解决方案分享

前言字符集是一套符号和编码的规则&#xff0c;不论是在oracle数据库还是在mysql数据库&#xff0c;都存在字符集的选择问题&#xff0c;而且如果在数据库创建阶段没有正确选择字符集&#xff0c;那么可能在后期需要更换字符集&#xff0c;而字符集的更换是代价比较高的操作&am…