文章目录
- 🐒个人主页
- 🏅JavaSE系列专栏
- 📖前言:
- 🎀什么是Stream流?
- 🧸流的概念
- 🐕如何获取流
- 🐕流的操作
- 🏅中间操作(返回类型都是流)
- filter:
- sorted():
- distinct:
- limit(n):
- skip(n):
- map():
- 🏅终端操作
- forEach:
- toArray:
- Min:
- Max:
- count:
- Reduce:
- anyMatch:
- allMatch:
- findFirst:
- collect:
🐒个人主页
🏅JavaSE系列专栏
📖前言:
本篇博客主要以介绍Stream流用法
🎀什么是Stream流?
我认为Stream流是将数据转为等待加工的流水线序列,经过一系列操作直接处理自己需要的数据。
Stream 是 Java8 的新特性
,它允许你以声明式的方式处理数据集合,可以把
它看作是遍历数据集的高级迭代器。此外与 stream 与 lambada 表达示结合后
编码效率与大大提高,并且可读性更强。
要澄清的是 java8 中的 stream 与 InputStream 和 OutputStream 是完全 不同的概念
.
🧸流的概念
简单的定义,就是“从支持数据处理操作的源,生成的元素序列”。
元素列表:和集合一样,流也提供了一个接口,访问特定元素类型的一组有序值。
数据源 :获取数据的源,比如集合。
数据处理操作 :流更偏向于数据处理和计算,比如 filter、map、find、sort 等。
简单来说,我们通过一个集合的 stream 方法获取一个流,然后对流进行一系列流操作,最后再构建成我们需要的数据集合。
🐕如何获取流
使用 Collection 接口下的 stream()
List<String> list = new ArrayList<>();
Stream<String> stream = list.stream();
使用 Arrays 中的 stream() 方法,将数组转成流
Integer[] nums = new Integer[10];
Stream<Integer> stream = Arrays.stream(nums);
使用 Stream 中的静态方法:of()
Stream<Integer> stream = Stream.of(1,2,3,4,5,6);
使用 BufferedReader.lines() 方法,将每行内容转成流
BufferedReader reader=new BufferedReader(new FileReader("stream.txt"));
Stream<String> lineStream = reader.lines();
//以下是流操作
🐕流的操作
可以分为中间操作与终端操作。
诸如 filter 或者 sort 等中间操作会返回另一个流,进而进行下一步流操作,而终
端操作则是将流关闭,构建新的数据集合对象(也可以不构建)。
🏅中间操作(返回类型都是流)
filter:
过滤流中的某些元素,
sorted():
自然排序,流中元素需实现 Comparable 接口
distinct:
去除重复元素
limit(n):
获取 n 个元素
skip(n):
跳过 n 元素,配合 limit(n)可实现分页
map():
将其映射成一个新的元素(就是将对象作为键,中的一个属性取出作为值)
🏅终端操作
forEach:
遍历流中的元素
toArray:
将流中的元素倒入一个数组
Min:
返回流中元素最小值
Max:
返回流中元素最大值
count:
返回流中元素的总个数
Reduce:
所有元素求和
anyMatch:
接收一个 Predicate 函数,只要流中有一个元素满足条件则返回 true,否则返回 false
allMatch:
接收一个 Predicate 函数,当流中每个元素都符合条件时才返回 true,否则返回 false
findFirst:
返回流中第一个元素
collect:
将流中的元素倒入一个集合,Collection 或 Map