Stream API

Stream API说明：

Stream是java8中处理集合的关键抽象概念，它可以指定你希望对集合进行的操作，可以执行非常复杂的查找，过滤和映射数据等操作
使用Stream Api 对集合数据进行操作，就类似于使用SQL执行的数据库查询，也可以使用Stream API 来执行并操作,Stream API提供了一种高效且易于使用的处理数据的方式 。

Stream 和Collection 集合的区别，Collection 是一种静态的内存数据结构，而Stream 是有关计算的。前者是主要面前内存，存储在内存中，后者主要是面向CPU，通过CPU实现计算的。

集合讲的是数据，Stream讲的是计算！

Stream的操作三个步骤

1.创建Stream
一个数据源 ，获取一个流

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

3.终止操作
一旦执行种植操作，就执行中间操作连，并产生结果，之后不会再使用。

若不执行终止操作 则不会进行中间操作，也就不会对数据进行处理。

创建Stream的四种方式

方式一 :通过集合

        List<Object> list =new ArrayList<>();
        Stream<Object> stream = list.stream();//返回一个顺序流 (按集合中的顺序来)
        Stream<Object> stream1 = list.parallelStream();//返回一个并行流(向多个线程一样执行)
1
2
3

方式二：通过数组

   int [] arr = new int[]{1,2,3,4,5,6};
        IntStream stream2 = Arrays.stream(arr);  //返回的类型是根据传入的类型决定的
1
2

方式三 通过Stream的of()

      Stream<Integer> stream3 = Stream.of(1, 2, 3, 4, 5);
1

方式四：创建无限流（了解一下）

中间操作

筛选与切片

filter

        int [] arr = new int[]{1,2,3,4,5,6};
        IntStream stream2 = Arrays.stream(arr);
		stream2.filter(value -> value>2).forEach(System.out::println);
1
2
3

注意我这里用同一个stream2 是因为我把上面那个注释了 不然的话一个Strem 在终止操作后就不存在了 不能重复使用
limit

       IntStream stream2 = Arrays.stream(arr);
        stream2.limit(3).forEach(System.out::println);

1
2
3

skip： 跳过几个元素

     IntStream stream2 = Arrays.stream(arr);
        stream2.skip(3).forEach(System.out::println);
1
2

distinct

        int [] arr = new int[]{1,2,3,4,4,5,6};
        IntStream stream2 = Arrays.stream(arr);
        stream2.distinct().forEach(System.out::println);
1
2
3

映射

map
自动遍历 放在str中

  String [] arr = new String[]{"a","b","c","d","e","f"};
        Stream<String> stream = Arrays.stream(arr);
        stream.map(str->str.toUpperCase()).forEach(System.out::println);
1
2
3

练习 ： 获得员工姓名长度大于三的员工姓名
1.首先先映射员工姓名 在进行过滤

List<Employee> employee =new ArrayList<>();
employee.stream().map(e->e.getName()).filter(name->name.length()>3).foreach(System.out::println)
1
2

排序

     Stream<String> stream = Arrays.stream(arr);
     stream.sorted().forEach(System.out::println);
1
2

对象类型的想要进行排序 需要实现Comparable接口 或者定制排序

这里假设有个员工类集合 需要按照 年龄进行排序
employees.stream().sorted((e1,e2)->{
return Integer.compare(e1.getAge(),e2.getAge());
}).forEach(System.out::println)
1
2
3
4

终止操作

匹配与查找

例子1 ： 判断是否所有员工的年龄都大于18

boolean allMatch=employees.stream().allMatch(e->e.getAge()>18);
1

规约

例子

计算 1- 10自然数的和

List<Integer> list = Arrays.alist(1,2,3,4,5,6,7,8,9,10);
Integer sum=list.stream().reduce(0,Integer::sum);
1
2

练习2: 计算公司所有员工工资总和

employees.stream().map(Employee:: getSalary).reduce(Double::sum)
employees.stream().map(Employee:: getSalary).reduce((d1,d2)->d1+d2)
1
2

收集

Collector 接口中的方法实现决定了如何对流执行收集的操作 如收集到(List ,Set Map)

练习： 查找工资大于6000的员工 结果返回一个List

employee.stream().filter(e- > e.getSalary()>6000).collect(Collectors.toList())
1