learning_record_doc/java/jdk8/Stream.md

## 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&lt;T&gt; extends BaseStream<T, Stream&lt;T&gt;> | 通用 | 支持顺序和并行操作的任意类型的元素流                     |
| interface DoubleStream extends BaseStream<Double, DoubleStream> | 数值 | 支持顺序和并行聚合操作的原始 double 值的元素流           |
| interface IntStream extends BaseStream<Integer, IntStream>   | 数值 | 支持顺序和并行聚合操作的原始 int 值的元素流              |
| interface LongStream extends BaseStream<Long, LongStream>    | 数值 | 支持顺序和并行聚合操作的原始 long 值的元素流             |

​		**BaseStream 抽象方法介绍**

| 方法                             | 类型     | 概述                                                         |
| -------------------------------- | -------- | ------------------------------------------------------------ |
| Iterator<T> iterator()           | 终端操作 | 返回此流的元素的迭代器                                       |
| Spliterator<T> 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<T>流来做讲解**

### Stream的创建方式

**下面我举例常用Stream流创建的方式，其中加粗的方法是用到最多的几种.**

| 创建方法                      | 方法类型 | 顺序流/并行流 |
| ----------------------------- | -------- | ------------- |
| **Stream.of**                 | 静态方法 | 顺序流        |
| Stream.generate               | 静态方法 | 顺序流        |
| Stream.builder                | 静态方法 | 顺序流        |
| Stream.iterate                | 静态方法 | 顺序流        |
| **Arrays.stream**             | 静态方法 | 顺序流        |
| **Collection.stream**         | 成员方法 | 顺序流        |
| **Collection.parallelStream** | 成员方法 | 并行流        |

> 并行流：内部以多线程并行执行的方式对流进行操作,因为是多线程并行操作所以无法保证集合数据的顺序，除了无法保证顺序以外还会有线程不安全的问题。

**案例演示**

```java
@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:大海大地大山
```

### Stream方法类型以及方法概述

### Stream方法案例演示

### Stream并行流

### Collectors