Stream01 定义迭代操作惰性求值

Posted 2020-11-20 neverctrl-c

 

1 Stream

　　Stream 是 Java 8 提供的一系列对可迭代元素处理的优化方案，使用 Stream 可以大大减少代码量，提高代码的可读性并且使代码更易并行。

 

2 迭代

　　2.1 需求

　　　　随机创建int类型的数组，计算数组中各个元素的总和

　　2.2 思路

　　　　2.2.1 外部迭代

　　　　　　通过for循环迭代数组

　　　　2.2.2 内部迭代

　　　　　　先将数组转化成流 -> 在通过流的相关操作来实现

　　　　2.2.3 外部迭代和内部迭代

　　　　　　外部迭代式串行的，如果要实现并行需要自己编写代码实现；内部迭代实现并行操作只需要调用一个parallel()操作即可以啦

　　2.3 代码实现

package demo01_iteration;

import org.junit.Before;
import org.junit.Test;

import java.util.Arrays;
import java.util.Random;
import java.util.stream.IntStream;

/**
 * @author 王杨帅
 * @create 2018-06-24 22:48
 * @desc 外部迭代和内部迭代
 **/
public class Case01 {

    private int [] nums;
    private int count = 4;
    private Random random;

    @Before
    public void init() {
        random = new Random();
        nums = new int[count];
        for (int i = 0; i < nums.length; i++) { // 随机产生数组元素
            nums[i] = random.nextInt(30);
        }
    }

    /**
     * 外部迭代：自己利用for训话实现
     */
    @Test
    public void test01() {
        int sum = 0;
        for (int i : nums) {
            sum += i;
        }
        System.out.println(Arrays.toString(nums) + " 各个元素的累加和为：" + sum);
    }

    /**
     * 内部迭代：利用流的相关方法实现
     */
    @Test
    public void test02() {
        int sum = 0;
        sum = IntStream.of(nums).parallel().sum();
        System.out.println(Arrays.toString(nums) + " 各个元素的累加和为：" + sum);
    }

}

View Code

 

3 操作

　　3.1 分类

　　　　3.1.1 中间操作

　　　　　　返回一个Stream流的操作

　　　　3.1.2 终止操作

　　　　　　返回一个结果的操作

　　3.2 代码体验

package demo02_operation;

import org.junit.Before;
import org.junit.Test;

import java.lang.reflect.Array;
import java.util.Arrays;
import java.util.Random;
import java.util.stream.IntStream;

/**
 * @author 王杨帅
 * @create 2018-06-24 23:04
 * @desc 中间操作、终止操作、惰性求值
 **/
public class Case01 {

    private int [] nums;
    private int count = 5;
    private Random random;

    @Before
    public void init() {
        random = new Random();
        nums = new int[count];
        for (int i = 0; i < nums.length; i++) {
            nums[i] = random.nextInt(30);
        }
    }

    /**
     * 终止操作: 返回一个结果的操作
     */
    @Test
    public void test01() {
        int sum = IntStream.of(nums).sum();
        System.out.println(Arrays.toString(nums) + " 各个元素之和为： " + sum);
    }

    /**
     * 中间操作：返回一个流的操作【例如：Map操作】
     */
    @Test
    public void test02() {
        System.out.println("老的数组为：" + Arrays.toString(nums));
        int [] newNums = IntStream.of(nums).map(s -> s + 2).toArray();
        System.out.println("新的数组为：" + Arrays.toString(newNums));
    }


}

View Code

 

4 惰性求值

　　如果流的操作中没有执行终止操作也不会执行中间操作

　　4.1 代码体验

package demo02_operation;

import org.junit.Before;
import org.junit.Test;

import java.lang.reflect.Array;
import java.util.Arrays;
import java.util.Random;
import java.util.stream.IntStream;

/**
 * @author 王杨帅
 * @create 2018-06-24 23:04
 * @desc 中间操作、终止操作、惰性求值
 **/
public class Case01 {

    private int [] nums;
    private int count = 5;
    private Random random;

    @Before
    public void init() {
        random = new Random();
        nums = new int[count];
        for (int i = 0; i < nums.length; i++) {
            nums[i] = random.nextInt(30);
        }
    }

    /**
     * 惰性求值
     */
    @Test
    public void test01() {
        System.out.println("老的数组为：" + Arrays.toString(nums));
//        IntStream.of(nums).map(Case01::addFive); // 没有终止操作，map操作不会执行
        IntStream.of(nums).map(Case01::addFive).sum(); // 有中间操作，map操作会执行
    }

    public static Integer addFive(Integer num) {
        System.out.println("中间操作执行了");
        return num + 5;
    }

}

View Code