6.3 KiB
6.3 KiB
Stream 流式操作
概述
java 8 是一个非常成功的版本，这个版本新增的Stream，配合同版本出现的Lambda ，给我们操作集合（Collection）提供了极大的便利。Stream流是JDK8新增的成员，允许以声明性方式处理数据集合，可以把Stream流看作是遍历数据集合的一个高级迭代器。Stream 是 Java8 中处理集合的关键抽象概念，它可以指定你希望对集合进行的操作，可以执行非常复杂的查找/筛选/过滤、排序、聚合和映射数据等操作。使用Stream API 对集合数据进行操作，就类似于使用 SQL 执行的数据库查询。也可以使用 Stream API 来并行执行操作。简而言之，Stream API 提供了一种高效且易于使用的处理数据的方式。
可以把Stream当作是一个工厂，我们要操作的集合数据作为原材料，原材料通过我们调用Stream的方法加工成所需的成品供我们使用。
Stream类型
jdk8提供了BaseStream流的基本接口,以及四种实现了BaseStream的Stream接口
| 接口 | 类型 | 概述 |
|---|---|---|
| interface BaseStream<T, S extends BaseStream<T, S>> | Stream流顶级接口所有的Stream都是基于BaseStream进行实现的 | |
| interface Stream<T> extends BaseStream<T, Stream<T>> | 通用 | 支持顺序和并行操作的任意类型的元素流 |
| interface DoubleStream extends BaseStream<Double, DoubleStream> | 数值 | 支持顺序和并行聚合操作的原始 double 值的元素流 |
| interface IntStream extends BaseStream<Integer, IntStream> | 数值 | 支持顺序和并行聚合操作的原始 int 值的元素流 |
| interface LongStream extends BaseStream<Long, LongStream> | 数值 | 支持顺序和并行聚合操作的原始 long 值的元素流 |
BaseStream 抽象方法介绍
| 方法 | 类型 | 概述 |
|---|---|---|
| Iterator iterator() | 终端操作 | 返回此流的元素的迭代器 |
| Spliterator spliterator() | 终端操作 | 返回此流的元素的拆分器 |
| boolean isParallel() | 检测stream是否为并行stream(执行过终端操作方法的流在执行此方法会出现不可预知的问题) | |
| S sequential() | 中间操作 | 返回一个顺序流 |
| S parallel() | 中间操作 | 返回一个并行流 |
| S unordered() | 中间操作 | 返回一个无序流 |
| S onClose(Runnable closeHandler) | 中间操作 | 返回具有附加关闭处理程序的等效流 |
| void close() | 关闭此流，从而调用此流管道的所有关闭处理程序 |
数值类型的Stream流额外提供了sum、average、boxed等方法，sum方法用于求和、average用于求平均值，boxed方法会将数值流转换为通用流；
下面我会以通用Stream流来做讲解
Stream的创建方式
下面我举例常用Stream流创建的方式，其中加粗的方法是用到最多的几种.
| 创建方法 | 方法类型 | 顺序流/并行流 |
|---|---|---|
| Stream.of | 静态方法 | 顺序流 |
| Stream.generate | 静态方法 | 顺序流 |
| Stream.builder | 静态方法 | 顺序流 |
| Stream.iterate | 静态方法 | 顺序流 |
| Arrays.stream | 静态方法 | 顺序流 |
| Collection.stream | 成员方法 | 顺序流 |
| Collection.parallelStream | 成员方法 | 并行流 |
并行流：内部以多线程并行执行的方式对流进行操作,因为是多线程并行操作所以无法保证集合数据的顺序，除了无法保证顺序以外还会有线程不安全的问题。
案例演示
@Test
public void test1(){
//通过Stream.of静态方法创建顺序流
Stream<Integer> stream1 = Stream.of(1, 2, 3);
System.out.print("stream1:");
stream1.forEach(System.out::print);
//通过Stream.generate静态方法创建顺序流
Stream<Double> stream2 = Stream.generate((Math::random)).limit(2);
System.out.print("\nstream2:");
stream2.forEach(System.out::print);
//通过Stream.builder静态方法创建顺序流
Stream<Object> stream3 = Stream.builder()
.add(4)
.add(5)
.add(6).build();
System.out.print("\nstream3:");
stream3.forEach(System.out::print);
//通过Stream.iterate静态方法创建顺序流
Stream<Integer> stream4 = Stream.iterate(0, (x) -> x + 10).limit(5);
System.out.print("\nstream4:");
stream4.forEach(System.out::print);
//通过Arrays.stream静态方法创建顺序流
Stream<Integer> stream5 = Arrays.stream(new Integer[]{7, 8, 9});
System.out.print("\nstream5:");
stream5.forEach(System.out::print);
Collection<String> collection = new ArrayList<>();
collection.add("大山");
collection.add("大海");
collection.add("大地");
//Collection.stream方法创建顺序流
Stream<String> stream6 = collection.stream();
System.out.print("\nstream6:");
stream6.forEach(System.out::print);
//通过Collection.parallelStream创建并行流
Stream<String> stream7 = collection.parallelStream();
System.out.print("\nstream7:");
stream7.forEach(System.out::print);
}
输出内容
stream1:123
stream2:0.63071892380716040.5348826766523751
stream3:456
stream4:010203040
stream5:789
stream6:大山大海大地
stream7:大海大地大山