Stream 操作

朴灿烈づ我的快乐病毒、 2022-05-28 13:26 118阅读 0赞

### 得到Stream对象 ###

List就可以得到一个Stream

List<String> list = new ArrayList<>();
    Stream<String> stream = list.stream();

数组也可以得到

String[] s = new String[10];
    Stream<String> stream2 = Arrays.stream(s);

也可以通过Stream自带的静态方法得到

Stream<String> stream3 = Stream.of("a","b","c");

### 遍历集合 ###

得到Stream，遍历集合

List<Integer> list =new ArrayList<>();
     list.add(12);
     list.add(22);
     list.add(32);
     list.add(19);
    
     list.stream().forEach(System.out::println);
     list.forEach(System.out::println);  //直接用也可以

### filter ###

Stream<Integer> stream = list.stream()
                    .filter(num -> num > 20);
            stream.forEach(System.out::println);

上面取出了list中值大于20的元素， 其中lambda代码num > 20 可以使用断定型函数接口Predicate代替如下：

Predicate<Integer> pre = (x) -> x>20;
    list.stream().filter(i -> pre.test(i))
                    .forEach(System.out::println);

Predicate 接口除了test()方法， 还有and(), or() 的方法如下， 过滤出长度>4 或者等于“b”的元素

List<String> names = Arrays.asList("aaaaaa","b","cc");
            Predicate<String> pre2 = str -> str.length() > 3;
            Predicate<String> pre3 = str -> str.compareTo("b") == 0;
            names.stream()
                    .filter(pre2.or(pre3))
                    .forEach(System.out::println);

### map ###

对每个元素进行遍历操作， 就像下面给list每个元素+3

list.stream().map(num -> num+3)
                    .forEach(System.out::println);

### reduce ###

用来合并， 累加等

System.out.println(list.stream().reduce(0, (x,y) -> x+y)); System.out.println(names.stream().reduce("",(x,y) -> x+y));

### 收集器 ###

通过过滤器或者map后， 使用收集器collect对数据进行收集， 返回一个原来类型的集合

List<String> nameList = names.stream().filter(x -> x.length() > 2).collect(Collectors.toList());

### 去重 ###

distinct 去掉重复值

list.stream().distinct().forEach(System.out::println);

### 统计 ###

IntSummaryStatistics  intSummaryStatistics = list.stream().mapToInt(x -> x).summaryStatistics();
            System.out.println(intSummaryStatistics.getCount());
            System.out.println(intSummaryStatistics.getMax());
            System.out.println(intSummaryStatistics.getSum());