java list stream 去除 null_Stream流的这些操作，你得知道，对你工作有很大帮助

作者：扬帆( ω )起航

原文：https://blog.csdn.net/qq_43677736

Stream流

Stream(流)是一个来自数据源的元素队列并支持聚合操作：

• 元素是特定类型的对象，形成一个队列。Java中的Stream并不会存储元素，而 是按需计算。

• 数据源 流的来源。可以是集合，数组等。

• 聚合操作类似SQL语句一样的操作， 比如filter, map, reduce, find, match, sorted 等。

Stream流操作的三个步骤：

1. 创建Stream

   一个数据源(如：集合、数组)，获取一个流

2. 中间操作

   一个中间操作链，对数据源的数据进行处理

3. 终止操作

   一个终止操作，执行中间操作链，并产生结果

创建Stream步骤：

• 通过Collection系列集合提供的顺序流stream()或并行流parallelStream()

• 通过Arrays中的静态方法stream()获取数据流

• 通过Stream类中的静态方法of()

代码实例：

package com.ysh.review01_Stream;
import java.util.Arrays;
import java.util.List;
import java.util.stream.Stream;

public class StreamTest01 {
    
    public static void main(String[] args) {
    
//第一种方式：通过集合中的stream()方法创建Stream
        List<String> list= Arrays.asList("红太狼","灰太狼","喜羊羊");
        Stream<String> stream=list.stream();
//通过集合中的parallelStream方法创建
        Stream<String> stream2 = list.parallelStream();
//第二种方式：通过java.util.Arrays下的静态方法stream创建Stream
        Integer[] integer=new Integer[]{
    1,2,4};
//这里需要注意的是Arrays中的stream方法里面的参数需要一个数组，且数组的类型是一个引用类型或者是一个包装类
        Stream<Integer> stream3 = Arrays.stream(integer);
//第三种方式：通过Stream中的of方法,实际上这种方式创建Stream实际上间接的通过调用Arrays中的stream()静态方法
        Stream<String> stream4=Stream.of("a","b","c");
}
}

Stream的中间操作

筛选和切片

filter：过滤器

package com.ysh.review01_Stream;

import java.util.Arrays;
import java.util.List;
import java.util.stream.Stream;

public class StramTest02 {
    
public static void main(String[] args) {
    
Employee employee01=new Employee("yang","hui",29);
Employee employee02=new Employee("yang","hui",49);
Employee employee03=new Employee("yang","hui",9);
Employee employee04=new Employee("yang","hui",89);
Employee employee05=new Employee("yang","hui",89);
Employee employee06=new Employee("yang","hui",89);
List<Employee> list= Arrays.asList(employee01,employee02,employee03,employee04,employee05,employee06);
//创建Stream
Stream<Employee> stream1 = list.stream();
//对stream1流进行过滤
Stream<Employee> s = stream1.filter((e) -> {
    
System.out.println("---------------filter------------");
//过滤掉年龄小于19
return e.getAge() >= 19;
});
        s.forEach((e-> System.out.println(e)));
}
}
class Employee {
    
private String id;
private String name;
private int age;

public Employee() {
    

}

public Employee(String id, String name, int age) {
    
this.id = id;
this.name = name;
this.age = age;
}

public String getId() {
    
return id;
}

public void setId(String id) {
    
this.id = id;
}

public String getName() {
    
return name;
}

public void setName(String name) {
    
this.name = name;
}

public int getAge() {
    
return age;
}

public void setAge(int age) {
    
this.age = age;
}

@Override
public boolean equals(Object o) {
    
if (this == o) return true;
if (o == null || getClass() !