Java Stream流的常见生成和操作方法总结

 更新时间:2022年09月18日 09:45:14   作者:夏志121  
从Java1.8开始提出了Stream流的概念,本文将通过示例为大家详细讲解一下Stream流的常见生成和操作方法,感兴趣的小伙伴可以了解一下

一、Stream流简单示例

需求:

按照要求集合创建和遍历

创建一个结合,存储多个字符串元素

把集合中所有以"张"开头的元素存储到一个新的集合

把"张"开头的集合中的长度为3的元素存储到一个新的集合

遍历上一步得到集合

原始方式示例代码:

public class StreamDemo {
    public static void main(String[] args) {
        //创建一个集合,存储多个字符串元素 
        ArrayList<String> list = new ArrayList<String>();
 
        list.add("心如音");
        list.add("流老蛋");
        list.add("王值");
        list.add("李尔");
        list.add("张新敏");
        list.add("张天坤");
 
        //把集合中所有以"张"开头的元素存储到一个新的集合 
        ArrayList<String> zhangList = new ArrayList<String>();
 
        for(String s : list) {
            if(s.startsWith("张")) {
                zhangList.add(s);
            }
        }
 
        // System.out.println(zhangList); 
 
        //把"张"开头的集合中的长度为3的元素存储到一个新的集合 
        ArrayList<String> threeList = new ArrayList<String>();
 
        for(String s : zhangList) {
            if(s.length() == 3) {
                threeList.add(s);
            }
        }
 
        // System.out.println(threeList); 
 
        //遍历上一步得到的集合 
        for(String s : threeList) {
            System.out.println(s);
        }
 
        System.out.println("--------");
        //Stream流来改进 
        // list.stream().filter(s -> s.startsWith("张")).filter(s -> s.length() == 3).forEach(s -> System.out.println(s));
        list.stream().filter(s -> s.startsWith("张")).filter(s -> s.length() == 3).forEach(System.out::println);
    }
}

使用Stream流示例代码:

public class StreamDemo {
    public static void main(String[] args) {
        //创建一个集合,存储多个字符串元素 
        ArrayList<String> list = new ArrayList<String>();
 
        list.add("心如音");
        list.add("流老蛋");
        list.add("王值");
        list.add("李尔");
        list.add("张新敏");
        list.add("张天坤");
 
        //Stream流来改进
        list.stream().filter(s -> s.startsWith("张")).filter(s -> s.length() ==
                3).forEach(System.out::println);
    }
}

二、Stream流常见生成方式

生成Stream流的方式:

Collection体系集合

使用默认方法stream()生成流,default Stream stream()

Map体系集合

把Map转成Set集合,间接生成流

数组

通过Stream接口的静态方法of(T...values)生成流

代码演示:

public class StreamDemo {
    public static void main(String[] args) {
        //Collection体系的集合可以使用默认方法stream()生成流 
        List<String> list = new ArrayList<String>();
        Stream<String> listStream = list.stream();
 
        Set<String> set = new HashSet<String>();
        Stream<String> setStream = set.stream();
 
        //Map体系的集合间接的生成流 
        Map<String,Integer> map = new HashMap<String, Integer>();
        Stream<String> keyStream = map.keySet().stream();
        Stream<Integer> valueStream = map.values().stream();
        Stream<Map.Entry<String, Integer>> entryStream = map.entrySet().stream();
 
        //数组可以通过Stream接口的静态方法of(T... values)生成流 
        String[] strArray = {"hello","world","java"};
        Stream<String> strArrayStream = Stream.of(strArray);
        Stream<String> strArrayStream2 = Stream.of("hello", "world", "java");
        Stream<Integer> intStream = Stream.of(10, 20, 30);
    }
}

三、Stream流中间操作方法

概念:

中间操作的意思是,执行完成此方法之后,Stream流依然可以继续执行其他操作

常见方法:

方法名说明
Stream fifilter(Predicate predicate)用于对流中的数据进行过滤
Stream limit(long maxSize)返回此流中的元素组成的流,截取前指定参数个数的数据
Stream skip(long n)跳过指定参数个数的数据,返回由该流的剩余元素组成的流
static Stream concat(Stream a, Stream b)合并a和b两个流为一个流
Stream distinct()返回由该流的不同元素(根据Object.equals(Object) )组成的流
Stream sorted()返回由此流的元素组成的流,根据自然顺序排序
Stream sorted(Comparator comparator)返回由该流的元素组成的流,根据提供的Comparator进行排序
Stream map(Function mapper)返回由给定函数应用于此流的元素的结果组成的流
IntStream mapToInt(ToIntFunction mapper)返回一个IntStream其中包含将给定函数应用于此流的元素的结果

filter代码示例

public class StreamDemo01 {
    public static void main(String[] args) {
        //创建一个集合,存储多个字符串元素 
        ArrayList<String> list = new ArrayList<String>();
 
        list.add("心如音");
        list.add("流老蛋");
        list.add("王值");
        list.add("李尔");
        list.add("张新敏");
        list.add("张天坤");
 
        //需求1:把list集合中以张开头的元素在控制台输出 
        list.stream().filter(s -> s.startsWith("张")).forEach(System.out::println);
        System.out.println("--------");
 
        //需求2:把list集合中长度为3的元素在控制台输出 
        list.stream().filter(s -> s.length() == 3).forEach(System.out::println);
        System.out.println("--------");
 
        //需求3:把list集合中以张开头的,长度为3的元素在控制台输出 
        list.stream().filter(s -> s.startsWith("张")).filter(s -> s.length() ==
                3).forEach(System.out::println);
    }
}

limit&skip代码示例

public class StreamDemo02 {
    public static void main(String[] args) {
        //创建一个集合,存储多个字符串元素 
        ArrayList<String> list = new ArrayList<String>();
 
        list.add("心如音");
        list.add("流老蛋");
        list.add("王值");
        list.add("李尔");
        list.add("张新敏");
        list.add("张天坤");
 
        //需求1:取前3个数据在控制台输出 
        list.stream().limit(3).forEach(System.out::println);
        System.out.println("--------");
 
        //需求2:跳过3个元素,把剩下的元素在控制台输出 
        list.stream().skip(3).forEach(System.out::println);
        System.out.println("--------");
 
        //需求3:跳过2个元素,把剩下的元素中前2个在控制台输出 
        list.stream().skip(2).limit(2).forEach(System.out::println);
    }
}

concat&distinct代码示例

public class StreamDemo03 {
    public static void main(String[] args) {
        //创建一个集合,存储多个字符串元素 
        ArrayList<String> list = new ArrayList<String>();
 
        list.add("心如音");
        list.add("流老蛋");
        list.add("王值");
        list.add("李尔");
        list.add("张新敏");
        list.add("张天坤");
 
        //需求1:取前4个数据组成一个流 
        Stream<String> s1 = list.stream().limit(4);
 
        //需求2:跳过2个数据组成一个流 
        Stream<String> s2 = list.stream().skip(2);
 
        //需求3:合并需求1和需求2得到的流,并把结果在控制台输出 
        Stream.concat(s1,s2).forEach(System.out::println); 
 
        //需求4:合并需求1和需求2得到的流,并把结果在控制台输出,要求字符串元素不能重复 
        Stream.concat(s1,s2).distinct().forEach(System.out::println);
    }
}

sorted代码示例

public class StreamDemo04 {
    public static void main(String[] args) {
        //创建一个集合,存储多个字符串元素 
        ArrayList<String> list = new ArrayList<String>();
 
        list.add("linqingxia");
        list.add("zhangmanyu");
        list.add("wangzuxian");
        list.add("liuyan");
        list.add("zhangmin");
        list.add("zhangwuji");
 
        //需求1:按照字母顺序把数据在控制台输出 
        list.stream().sorted().forEach(System.out::println); 
 
        //需求2:按照字符串长度把数据在控制台输出 
        list.stream().sorted((s1,s2) -> {
            int num = s1.length()-s2.length();
            int num2 = num==0?s1.compareTo(s2):num;
            return num2;
        }).forEach(System.out::println);
    }
}

map&mapToInt代码示例

public class StreamDemo05 {
    public static void main(String[] args) {
        //创建一个集合,存储多个字符串元素 
        ArrayList<String> list = new ArrayList<String>();
 
        list.add("10");
        list.add("20");
        list.add("30");
        list.add("40");
        list.add("50");
 
        //需求:将集合中的字符串数据转换为整数之后在控制台输出 
        list.stream().map(s -> Integer.parseInt(s)).forEach(System.out::println); 
        list.stream().map(Integer::parseInt).forEach(System.out::println); 
        list.stream().mapToInt(Integer::parseInt).forEach(System.out::println); 
 
        //int sum() 返回此流中元素的总和 
        int result = list.stream().mapToInt(Integer::parseInt).sum();
        System.out.println(result);
    }
}

到此这篇关于Java Stream流的常见生成和操作方法总结的文章就介绍到这了,更多相关Java Stream流内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • springmvc 获取@Requestbody转换的异常处理方式

    springmvc 获取@Requestbody转换的异常处理方式

    这篇文章主要介绍了springmvc 获取@Requestbody转换的异常处理方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-07-07
  • 配置java.library.path加载库文件问题

    配置java.library.path加载库文件问题

    这篇文章主要介绍了配置java.library.path加载库文件问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-12-12
  • java实现pdf按页转换为图片

    java实现pdf按页转换为图片

    这篇文章主要为大家详细介绍了java实现pdf按页转换为图片,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2018-12-12
  • Java 程序员必备的 Intellij IDEA 插件

    Java 程序员必备的 Intellij IDEA 插件

    java插件十分方便实用,以下是我用过不错的Intellij插件,当然还有很多插件也都不错,下面将我觉得不错的插件分享给大家,希望能帮到大家
    2018-09-09
  • 详细介绍Spring的配置文件

    详细介绍Spring的配置文件

    这篇文章主要为大家详细介绍了Spring中的配置文件的命名以及它的配置文件都有些什么。文中的示例代码讲解详细,感兴趣的小伙伴可以跟上小编一起学习一下
    2022-10-10
  • Java线程阻塞和唤醒的几种方式详解

    Java线程阻塞和唤醒的几种方式详解

    这篇文章主要介绍了Java线程阻塞和唤醒的几种方式详解,线程阻塞是指当一个线程无法继续执行时,它会进入阻塞状态,直到某个条件满足后才能继续执行,线程阻塞可以通过多种方式实现,如等待锁、等待IO操作、等待其他线程的完成等,需要的朋友可以参考下
    2023-10-10
  • Admin - SpringBoot + Maven 多启动环境配置实例详解

    Admin - SpringBoot + Maven 多启动环境配置实例详解

    这篇文章主要介绍了Admin - SpringBoot + Maven 多启动环境配置,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2021-03-03
  • Java设计模式的事件模型详解

    Java设计模式的事件模型详解

    这篇文章主要为大家详细介绍了Java设计模式的事件模型,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下,希望能够给你带来帮助
    2022-03-03
  • Java实现学生管理系统

    Java实现学生管理系统

    这篇文章主要为大家详细介绍了Java实现学生管理系统,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2018-01-01
  • Java从同步容器到并发容器的操作过程

    Java从同步容器到并发容器的操作过程

    这篇文章主要介绍了Java从同步容器到并发容器的操作过程,非常不错,具有一定的参考借鉴价值,需要的朋友可以参考下
    2018-10-10

最新评论