Steam流初探

一 定义

 流是一个元素的序列，支持串行(单线程)和并行(多线程)的操作。涉及到的类基本都在java.util.stream包下，除了Stream之外，还有元素是基本类型的IntStream、DoubleStream等。
 流的基本结构：一个源（数组、集合、I/O等等），零个或者多个中间操作，一个终止操作。其中中间操作就是数据转换，比如map、filter等等，终止操作就是源数据经过数据转换的操作结果，比如count、reduce等。

stream.xxx().yyy().zzz().count();
stream就是源
xxx、yyy、zzz都是中间操作，中间操作的返回值都是Stream,count()就是终止操作

 流与集合的区别:
 集合的关注点在于更好的存储和访问数据，比如存储数据时选择链表还是树结构存储，而流的意义在于为了理想的结果对数据源执行的聚合操作，比如筛选源数据中符合某条件的元素，对源数据的元素执行转换等等。

二 流的特点

 ①流本身不存储值，通过管道的方式获取值，因此它对源数据是不修改的。
 ②流中的参数基本都是代表某一行为的函数式接口，非常适合和Lambda表达式配合。
 ③流的流的很多操作都是可以Lazy的，如果没终止操作(count)，前面的操作都不执行

三 流的创建

 ①Stream的静态方法
 ②根据数组
 ③根据集合

        //静态方法
        //of参数为一个可变的参数
        Stream<Integer> stream=Stream.of(1,2,3,4,5);

        //数组
        Integer[] ints={1,2,3,4,5};
        //和上面的静态方法创建一样，利用可变参数
        Stream<Integer> integerStream=Stream.of(ints);
        //利用Arrays的工具方法
        Stream<Integer> integerStream1 = Arrays.stream(ints);


        //根据集合
        List<Integer> list=Arrays.asList(1,2,3,4,5);
        Stream<Integer> intStream = list.stream();

四 实例

 将数组的元素取平方后求和输出

public class StreamTest {
    public static void main(String[] args) {
        List<Integer> integerList = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);

        //原来的方式 
        int sum = 0;
        for (int i = 0; i < integerList.size(); i++) {
            sum += integerList.get(i) * integerList.get(i);
        }
        System.out.println(sum);

        //使用流的方式
        //匿名类
        integerList.stream()//构建流
                .map(new Function<Integer, Integer>() {
                    //函数式接口  接受一个参数，返回一个结果
                    //类型为(int)->{int}
                    @Override
                    public Integer apply(Integer integer) {
                        //integer 为元素
                        //integer*integer 定义的计算规则 元素平方
                        return integer*integer;
                    }
                })
                .reduce(0, new BinaryOperator<Integer>() {
                    //函数式接口 接受两个参数，返回一个结果
                    //类型为(int,int)->int
                    @Override
                    public Integer apply(Integer integer, Integer integer2) {
                        //integer为前面计算的结果 integer2为待计算的元素
                        //integer+integer2 定义的计算规则 累加
                        return integer+integer2;
                    }
                });
        
        //lambda表达式
        int streamSum = integerList.stream()
                .map(it -> it * it)
                .reduce(0, Math::addExact);
        
        
        System.out.println(streamSum);

    }
}

五 流的注意点

 流已经被操作了或者被关闭了---->异常

System.out.println(stream);
System.out.println(stream.filter());
System.out.println(stream.map());//就是上述的异常
//可以链式调用 但不能上面例子那样调用