Java:Stream流

导读:本篇文章讲解 Java:Stream流,希望对大家有帮助,欢迎收藏,转发!站点地址:www.bmabk.com

目录

Stream流

1、Stream流的使用步骤

2、Stream流的获取方式

3、Stream流的中间方法

4、Stream流的终结方法


Stream流

作用:结合了Lambda表达式,简化集合、数组的操作

1、Stream流的使用步骤

1、先得到一条Stream流(流水线),并把数据放上去

2、使用中间方法对流水线上的数据进行操作

3、使用终结方法对流水线上的数据进行操作

利用Stream流中的API进行各种操作

过滤 转换 中间方法 方法调用完毕之后,还可以调用其他方法
 
统计 打印 终结方法
 
最后一步,调用完毕之后,不能调用其他方法
 

2、Stream流的获取方式

 获取方式 方法名 说明
单列集合
 
default Stream<E> stream()
 
collection中的默认方法
 
双列集合
 
无法直接使用stream流
 
数组
 
public static <T> Stream<T> stream(T[ ]array)
 
Arrays工具类中的静态方法
 
一堆零散数据
 
public static<T> Stream<T> of(T… values)
 
Stream接口中的静态方法

单列集合

        List<String> list = new ArrayList<>();
        Collections.addAll(list,"a","s","d","f");
        //获取一条流水线,并把数据放在流水线上
        Stream<String> stream = list.stream();
        //使用终结方法打印流水线所有数据
        stream.forEach(new Consumer<String>() {
            @Override
            public void accept(String s) {
                System.out.println(s);
            }
        });
        System.out.println("-----------------");
        //简化
        list.stream().forEach(s -> System.out.println(s));

双列集合

        //1.创建双列集合
        HashMap<String,Integer> hm = new HashMap<>();
        //2.添加数据
        hm.put("aaa",111);
        hm.put("bbb",222);
        hm.put("ccc",333);
        hm.put("ddd",444);
        //3.第一种获取stream流
        // hm.keySet().stream( ).forEach(s -> system.out.println(s)) ;
        //4.第二种获取stream流
        hm.entrySet().stream( ).forEach(s-> System.out.println(s)) ;

数组

         //1.创建数组
        int[] arr1 = {1,2,3,4,5};
        String[] arr2 = {"a","b","c"};
        //2.获取stream流
        Arrays.stream( arr1).forEach(s-> System.out.println(s)) ;
        System.out.println( "-----------------------");
        Arrays.stream( arr2).forEach(s-> System.out.println(s));

零散数据

Stream.of(1,2,3,4,5).forEach(s-> System.out.println(s));
System.out.println("-----------------");
Stream.of("a","b","c").forEach(s-> System.out.println(s));

注意:

Stream接口中静态方法of的细节

方法的形参是一个可变参数,可以传递一堆零散的数据,也可以传递数组,但是数组必须是引用数

据类型的,如果传递基本数据类型,是会把整个数组当做一个元素,放到Stream当中。

3、Stream流的中间方法

名称 说明
Stream<T> filter(Predicate<? super T> predicate) 过滤
Stream<T> limit(long maxSize) 获取前几个元素
Stream<T> skip(long n) 跳过前几个元素
Stream<T> distinct() 元素去重,依赖(hashcode和equals方法)
static <T> Stream<T> concat(Stream a, Stream b) 合并a和b两个流为一个流
Stream<R> map(Function<T , R> mapper) 转换流中的数据类型

注意1∶中间方法,返回新的Stream流,原来的Stream流只能使用一次,建议使用链式编程、

注意2:修改Stream流中的数据,不会影响原来集合或者数组中的数据
示例:

ArrayList<String> list = new ArrayList<>();
Collections.addAll(list,"张无忌","周芷若", "赵敏" ,"张强","张三丰","张翠山","张良","王二麻子","谢广坤");
//filter过滤把张开头的留下,其余数据过滤不要
list.stream().filter(new Predicate<String>() {
      @Override
       public boolean test(String s) {
            //如果返回值为true,表示当前数据留下
            //如果返回值为false,表示当前数据舍弃不要
            return s.startsWith("张");
       }
   }).forEach(s -> System.out.println(s));
System.out.println("-----------------");
//简化 
//是否有张,长度是否等于3
list.stream().filter(s -> s.startsWith("张")).filter(s -> s.length() == 3).forEach(s -> System.out.println(s));
System.out.println("-----------------------");
//获取前几个元素
list.stream().limit(3).forEach(s -> System.out.println(s));
System.out.println("--------------------");
//跳过前几个元素
list.stream().skip(4).forEach(s -> System.out.println(s));
System.out.println("--------------------");
//元素去重
ArrayList<String> list1 = new ArrayList<>();
Collections.addAll(list1, "张无忌","张无忌","张无忌","张强","张三丰","张举山","张良","王二麻子","谢广坤");
ArrayList<String> list2 = new ArrayList<>();
Collections.addAll(list2,"周芷若","赵敏");
// distinct 元素去重,依赖(hashcode和equals方法)
list1.stream().distinct() .forEach(s -> System.out.println( s)) ;
System.out.println("--------------------");
//合并两个流
Stream.concat(list1.stream(),list2.stream()).forEach(s -> System.out.println(s));

4、Stream流的终结方法

名称 说明
void forEach(Consumer action) 遍历
long count() 统计
toArray() 收集流中的数据,放到数组中
collect(Collector collector) 收集流中的数据,放到集合中

遍历

ArrayList<String> list = new ArrayList<>();
Collections.addAll(list,"张无忌","周芷若", "赵敏" ,"张强","张三丰","张翠山","张良","王二麻子","谢广坤");
// Consumer的泛型:表示流中数据的类型
// accept方法的形参s:依次表示流里面的每一个数据
// 方法体:对每一个数据的处理操作(打印>|
list.stream().forEach(new Consumer<String>() {
      @Override
      public void accept(String s) {
          System.out.println(s);
      }
   });
//简化
list.stream().forEach(s -> System.out.println(s));

统计

 //统计
long count = list.stream().count();
System.out.println(count);

收集流中的数据,放到数组中

        //空参
        Object[] objects = list.stream().toArray();
        System.out.println(Arrays.toString(objects));

        //有参
        //IntFunction的泛型:具体类型的数组
        // apply的形参:流中数据的个数,要跟数组的长度保持一致
        // apply的返回值:具体类型的数组
        //方法体:就是创建数组

        //toArray方法的参数的作用:负责创建一个指定类型的数组
        // toArray方法的底层,会依次得到流里面的每一个数据,并把数据放到数组当中
        // toArray方法的返回值:是一个装着流里面所有数据的数组
        //匿名内部类
        String[] strings = list.stream().toArray(new IntFunction<String[]>() {
            @Override
            public String[] apply(int value) {
                return new String[value];
            }
        });
        System.out.println(Arrays.toString(strings));
        //lambda表达式的写法
        String[] strings1 = list.stream().toArray(value -> new String[value]);
        System.out.println(Arrays.toString(strings1));

收集流中的数据,放到集合中

         ArrayList<String> list = new ArrayList<>();
        Collections.addAll(list,"张无忌-男-20","周芷若-女-20");
        //收集在list集合中
        List<String> collect = list.stream().collect(Collectors.toList());
        System.out.println(collect);
        //收集在set集合中,可以去除重复元素
        Set<String> collect1 = list.stream().collect(Collectors.toSet());
        System.out.println(collect1);
        //收集在map集合中
        Map<String, Integer> collect2 = list.stream().collect(Collectors.toMap(
                s -> s.split("-")[0],
                s -> Integer.parseInt(s.split("-")[2])));
        System.out.println(collect2);

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

文章由半码博客整理,本文链接:https://www.bmabk.com/index.php/post/93334.html

(0)

相关推荐

半码博客——专业性很强的中文编程技术网站,欢迎收藏到浏览器,订阅我们!