一 定義

?流是一個(gè)元素的序列，支持串行(單線程)和并行(多線程)的操作。涉及到的類基本都在java.util.stream包下，除了Stream之外，還有元素是基本類型的IntStream、DoubleStream等。
?流的基本結(jié)構(gòu)：一個(gè)源（數(shù)組、集合、I/O等等），零個(gè)或者多個(gè)中間操作，一個(gè)終止操作。其中中間操作就是數(shù)據(jù)轉(zhuǎn)換，比如map、filter等等，終止操作就是源數(shù)據(jù)經(jīng)過(guò)數(shù)據(jù)轉(zhuǎn)換的操作結(jié)果，比如count、reduce等。

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

?流與集合的區(qū)別:
?集合的關(guān)注點(diǎn)在于更好的存儲(chǔ)和訪問(wèn)數(shù)據(jù)，比如存儲(chǔ)數(shù)據(jù)時(shí)選擇鏈表還是樹結(jié)構(gòu)存儲(chǔ)，而流的意義在于為了理想的結(jié)果對(duì)數(shù)據(jù)源執(zhí)行的聚合操作，比如篩選源數(shù)據(jù)中符合某條件的元素，對(duì)源數(shù)據(jù)的元素執(zhí)行轉(zhuǎn)換等等。

二 流的特點(diǎn)

?①流本身不存儲(chǔ)值，通過(guò)管道的方式獲取值，因此它對(duì)源數(shù)據(jù)是不修改的。
?②流中的參數(shù)基本都是代表某一行為的函數(shù)式接口，非常適合和Lambda表達(dá)式配合。
?③流的流的很多操作都是可以Lazy的，如果沒(méi)終止操作(count)，前面的操作都不執(zhí)行

三 流的創(chuàng)建

?①Stream的靜態(tài)方法
?②根據(jù)數(shù)組
?③根據(jù)集合

        //靜態(tài)方法
        //of參數(shù)為一個(gè)可變的參數(shù)
        Stream<Integer> stream=Stream.of(1,2,3,4,5);

        //數(shù)組
        Integer[] ints={1,2,3,4,5};
        //和上面的靜態(tài)方法創(chuàng)建一樣，利用可變參數(shù)
        Stream<Integer> integerStream=Stream.of(ints);
        //利用Arrays的工具方法
        Stream<Integer> integerStream1 = Arrays.stream(ints);


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

四 實(shí)例

?將數(shù)組的元素取平方后求和輸出

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

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

        //使用流的方式
        //匿名類
        integerList.stream()//構(gòu)建流
                .map(new Function<Integer, Integer>() {
                    //函數(shù)式接口  接受一個(gè)參數(shù)，返回一個(gè)結(jié)果
                    //類型為(int)->{int}
                    @Override
                    public Integer apply(Integer integer) {
                        //integer 為元素
                        //integer*integer 定義的計(jì)算規(guī)則 元素平方
                        return integer*integer;
                    }
                })
                .reduce(0, new BinaryOperator<Integer>() {
                    //函數(shù)式接口 接受兩個(gè)參數(shù)，返回一個(gè)結(jié)果
                    //類型為(int,int)->int
                    @Override
                    public Integer apply(Integer integer, Integer integer2) {
                        //integer為前面計(jì)算的結(jié)果 integer2為待計(jì)算的元素
                        //integer+integer2 定義的計(jì)算規(guī)則 累加
                        return integer+integer2;
                    }
                });
        
        //lambda表達(dá)式
        int streamSum = integerList.stream()
                .map(it -> it * it)
                .reduce(0, Math::addExact);
        
        
        System.out.println(streamSum);

    }
}

五 流的注意點(diǎn)

?流已經(jīng)被操作了或者被關(guān)閉了---->異常

System.out.println(stream);
System.out.println(stream.filter());
System.out.println(stream.map());//就是上述的異常
//可以鏈?zhǔn)秸{(diào)用 但不能上面例子那樣調(diào)用