强大的Stream API

Stream API的概述

*  1. Stream关注的是对数据的运算，与CPU打交道
*     集合关注的是数据的存储，与内存打交道
*
*  2. Stream 自己不会储存元素。
*     Stream 不会改变源对象。相反，他们会返回一个持有结果的新Stream。
*     Stream 操作是延迟执行的。这意味着他们会等到需要结果的时候才执行
*
*  3. Stream 执行流程
*     ① Stream的实例化
*     ② 一系列的中间操作(过滤、映射、...)
*     ③ 终止操作
*
*  4. 说明
*     ①一个中间操作链，对数据源的数据进行处理
*     ②一旦执行终止操作，就执行中间操作链，并产生结果。之后，此Stream不能再被使用
*

Stream的实例化

方式一: 通过集合

EmployeeData
提供用于测试的数据

/**
 * 提供用于测试的数据
 * 
 * @author 阿昌 邮箱：995931576@qq.com
 *
 */
public class EmployeeData {
   
   public static List<Employee> getEmployees(){
      List<Employee> list = new ArrayList<>();
      
      list.add(new Employee(1001, "马化腾", 34, 6000.38));
      list.add(new Employee(1002, "马云", 12, 9876.12));
      list.add(new Employee(1003, "刘强东", 33, 3000.82));
      list.add(new Employee(1004, "雷军", 26, 7657.37));
      list.add(new Employee(1005, "李彦宏", 65, 5555.32));
      list.add(new Employee(1006, "比尔盖茨", 42, 9500.43));
      list.add(new Employee(1007, "任正非", 26, 4333.32));
      list.add(new Employee(1008, "扎克伯格", 35, 2500.32));
      
      return list;
   }
   
}

    //创建Stream方式一: 通过集合
    @Test
    public void test1(){
        List<Employee> employees = EmployeeData.getEmployees();

//      default Stream<E> stream() : 返回一个顺序流
        Stream<Employee> stream = employees.stream();

//      default Stream<E> parallelStream() : 返回一个并行 (并行操作的去获取数据)
        Stream<Employee> parallelStream = employees.parallelStream();

    }

创建Stream方式二: 通过数组

    //创建Stream方式二: 通过数组
    @Test
    public void test2(){
        int[] arr1 = new int[]{1,2,3,4,5,6,7,8,9,10};
//      调用Arrays类的静态方法: static <T> Stream<T> stream(T[] array): 返回一个
        IntStream stream = Arrays.stream(arr1);

        Employee e1 = new Employee(1001,"李小姐");
        Employee e2 = new Employee(1002,"张先生");
        Employee[] arr2 = new Employee[]{e1,e2};
        Stream<Employee> stream1 = Arrays.stream(arr2);

    }

创建Stream方式三: 通过Stream的of()

//创建Stream方式三: 通过Stream的of()
@Test
public void test3(){
    Stream<Integer> integerStream = Stream.of(2, 3, 4, 8, 9, 6);
    
}

创建Stream方式四: 创建无限流

    //创建Stream方式四: 创建无限流
    @Test
    public void test4(){
//   迭代  public static<T> Stream<T> iterate(final T seed, final UnaryOperator<T> f)
        //遍历从前十个偶数
        Stream.iterate(0,t -> t + 2).limit(10).forEach(System.out::println);

//   生成  public static<T> Stream<T> generate(Supplier<T> s)
        //生成输出10个随机数
        Stream.generate(Math::random).limit(10).forEach(System.out::println);
        
    }