Java8-如何构建一个Stream

Stream的创建方式有很多种,除了最常见的集合创建,还有其他几种方式。

List转Stream

List继承自Collection接口,而Collection提供了stream()方法。

List<Integer> list = Lists.newArrayList(1, 2, 3);
Stream<Integer> stream = list.stream();

数组转stream

对于数组,Arrays提供了stream()方法。

String[] arr = new String[]{"a", "b", "c"};
Stream<String> stream = Arrays.stream(arr);

Map转stream

Map并不是一个序列,不是集合,没办法直接转成stream(). 但entrySet()是Set,可以转


Map<String, Object> map = Maps.newHashMap();
Stream<Entry<String, Object>> stream = map.entrySet().stream();

直接创建Stream

Stream也提供了API直接生成一个Stream,这个Stream大概可以理解成一个List。因为内部就是数组实现的。

Stream<Integer> integerStream = Stream.of(1, 2, 3);

读取文件的Stream

用过Linux的就会对其命令行的管道符敬佩不已,一个管道符就可以源源不断的做处理。在Java里读取文件也可以实现类似的功能。


long uniqueWords = 0;
try (Stream<String> lines = Files.lines(Paths.get("data.txt"), Charset.defaultCharset())) {uniqueWords = lines.flatMap(l -> Arrays.stream(l.split(" "))).distinct().count();
} catch (IOException e) {//
}

通过函数来生成无限流

Stream提供了iterate来生成一个无限序列,一个基于初始值的无限序列。可以用lambda设置序列的生成规则,比如每次增加2.

Stream.iterate(0, n -> n + 2).limit(10).forEach(System.out::println);

再比如,斐波那契数列(Fibonacci sequence)


Stream.iterate(new int[]{0, 1}, t -> new int[]{t[1], t[0] + t[1]}).limit(20).map(t -> t[0]).forEach(System.out::println);

Stream还提供了另一个generate方法来生成序列。接收一个用户指定的生成序列函数IntSupplier.

IntSupplier fib = new IntSupplier() {private int previous = 0;private int current = 1;@Overridepublic int getAsInt() {int oldPrevious = this.previous;int nextValue = this.previous + this.current;this.previous = this.current;this.current = nextValue;return oldPrevious;}
};
IntStream.generate(fib).limit(10).forEach(System.out::println);

转载于:https://www.cnblogs.com/woshimrf/p/Java8-build-stream.html

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

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

相关文章

软件产品案例分析

软件产品案例分析 第一部分&#xff1a; 评测&#xff1a; 上手体验&#xff1a; 说实话&#xff0c;在老师布置这个作业之前我确实不知道有K米这个APP&#xff0c;我想这是很少去KTV的原因吧。。。不过在接到这个作业后&#xff0c;我就去百度了普及了一下这个app的相关知识。…

java/android 做题中整理的碎片小贴士(12)

1、edittext中设置最长字数&#xff0c;可在xml中加入android:maxLength"10"&#xff0c;可在java代码中加入editText.setFilters(new InputFilter[]{new InputFilter.LengthFilter(20)}); 2、edittext监听软键盘delete按键&#xff1a; Et.setOnKeyListener(new Vi…

POJ2777(线段树裸题)

题目&#xff1a;http://poj.org/problem?id2777 别忘了各地的return&#xff1b; 有可能输入的L<R&#xff0c;手动swap&#xff1b; 似乎是多组输入&#xff1f; pushup和pushdown的位置。 &#xff08;原来pushup只有一行&#xff09; 要开四倍数组。是这种写法的原因吧…

vue --- 2.0 编译的实现

初识 假设html中有如下dom: <div id"app"><!-- 插值绑定 --><p>{{name}}</p><!-- 指令解析 --><p l-text"name"></p><p>{{age}}</p><p>{{doubleAge}}</p><!-- 双向绑定实现 -->…

个人作业收官——软件工程实践总结

一、回望与展望 1.1 对比现在和开学初博客开篇的课程目标和期待 当初的目标&#xff1a; 提升团队合作的能力能够学习到开发的一系列流程&#xff0c;以及如何写高质量的代码加强自己的编码能力&#xff0c;以及编码习惯熟悉不同平台的开发过程 如今&#xff1a; 基本的目标都…

sklearn中SVM调参说明

写在前面 之前只停留在理论上&#xff0c;没有实际沉下心去调参&#xff0c;实际去做了后&#xff0c;发现调参是个大工程&#xff08;玄学&#xff09;。于是这篇来总结一下sklearn中svm的参数说明以及调参经验。方便以后查询和回忆。 常用核函数 1.linear核函数: K(xi,xj)xTi…

TZOJ 3030 Courses(二分图匹配)

描述 Consider a group of N students and P courses. Each student visits zero, one or more than one courses. Your task is to determine whether it is possible to form a committee of exactly P students that satisfies simultaneously the conditions: every stude…

vue --- configureWebpack模拟后台数据

初识 使用vue/cli搭建的项目可以在vue.config.js中,模拟一个后台(express写法)vue.config.js configureWebpack: {devServer: {// 模拟后台服务器 express写法before(app) {app.get(/api/login, function(req, res) {const { username, passwd } req.query;console.log(user…

TCP和UDP的优缺点及区别

转自&#xff1a;http://www.cnblogs.com/xiaomayizoe/p/5258754.html TCP的优点&#xff1a; 可靠&#xff0c;稳定 TCP的可靠体现在TCP在传递数据之前&#xff0c;会有三次握手来建立连接&#xff0c;而且在数据传递时&#xff0c;有确认、窗口、重传、拥塞控制机制&#xff…

e.getMessage 为空NULL

e.getMessage 为空NULL 在日常代码中免不了要try catch 切忌用try catch 去try 整个方法。 在对象操作之前尽量写上if 空判断。 反例&#xff1a; public void send(){ try{ 代码1&#xff1a;获取对象 代码2&#xff1a;操作代码1 代码3&#xff1a;操作代码2 代码4&#xff1…

Linux:客户端的实现

写了一个简单的服务器软件&#xff0c;但是没有写客户端。现在我将客户端实现了&#xff0c;其实昨天已经说了客户端的实现步骤了。 步骤&#xff1a; socket() 初始化 connet()链接 从标准输入读数据fgets() 传数据到服务器write() 读从服务器返回的数据read() 写数据到屏幕上…

vue --- http拦截,登录登出的逻辑设计

设计 在src目录下创建一个interceptor.js登录逻辑 设置拦截,在发起请求前,先判断用户是否登录(在本栗中,即是否能够在浏览器缓存中找到token). 登出逻辑 对服务端传过来的数据进行拦截,判断其状态码是否为401(未登录或token过期)清空浏览器缓存中的token重定向到登入页面 inte…

循环分支循环语句

# 三大结构 - 循环 - 分支 - 循环 . . .In [ ]:# 分支 - 分支的基本语法 - if 条件表达式&#xff1a; 语句1 语句2 语句3 ..... - 条件表达式就是计算结果必须是布尔值的表达式 - 表达式后面的冒号觉对不能少 - 注意 if 后面出现的语句&#xff0c;如果属于 if 语句块&…

HTTP 1.1与HTTP 1.0的比较

HTTP 1.1与HTTP 1.0的比较 一个WEB站点每天可能要接收到上百万的用户请求&#xff0c;为了提高系统的效率&#xff0c;HTTP 1.0规定浏览器与服务器只保持短暂的连接&#xff0c;浏览器的每次请求都需要与服务器建立一个TCP连接&#xff0c;服务器完成请求处理后立即断开TCP连接…

vue --- 前端代理发送http请求

后端 端口在3000使用jsonwebtoken和koa-jwt生成令牌并返回对’/api/userinfo’端口,先验证令牌是否通过,若通过返回数据 const Koa require(koa); const Router require(koa-router); // 生成令牌、验证令牌 const jwt require(jsonwebtoken); const jwtAuth require(koa…

python全栈开发-json和pickle模块(数据的序列化)

一、什么是序列化&#xff1f; 我们把对象(变量)从内存中变成可存储或传输的过程称之为序列化&#xff0c;在Python中叫pickling&#xff0c;在其他语言中也被称之为serialization&#xff0c;marshalling&#xff0c;flattening等等&#xff0c;都是一个意思。 为什么要序列化…

Gale-Shapley---婚姻匹配算法算法

原文链接&#xff1a;http://blog.csdn.net/cscmaker/article/details/8291131 &#xff08;一&#xff09;问题的引出&#xff1a; 有N男N女&#xff0c;每个人都按照他对异性的喜欢程度排名。现在需要写出一个算法安排这N个男的、N个女的结婚&#xff0c;要求两个人的婚姻应该…

大数据排重

注意用来排重的那个集合放到Set中&#xff0c; 可以是HashSet,或者其他Set(推荐使用HashSet),因为Set的contains效率更高&#xff0c;比list高很多 -----------------------------------------------------------------------------------------------------------------------…

大前端成长路径

路径(持续更新): 以下是我不同时期的博客链接可以和我的GitHub共同食用大家可以对比一下,我学的过程是缓慢型的… learning: 0个月 2018年09月开始接触前端,前端三剑客一个不知道一个不懂,于是对着W3C、菜鸟教程.一个一个敲开始啃红宝书《JavaScript高级程序设计》(第3版) le…

工具:meson+ninja(安装问题解决)

问题1&#xff1a;Python版本问题 报错信息&#xff1a; NOTICE: You are using Python 3.6 which is EOL. Starting with v0.62.0, Meson will require Python 3.7 or newer ubuntu 18默认的python3是3.6. 解决方案1&#xff1a;从源码安装python 3.7 wget https://www.pyth…