• Java学习笔记（三十五）

    在完成对C语言的学习后，我最近开始了对C++和Java的学习，目前跟着视频学习了一些语法，也跟着敲了一些代码，有了一定的掌握程度。现在将跟着视频做的笔记进行整理。本篇博客是整理Java知识点的第三十五篇博客。

    本篇博客介绍了Java的Stream流。

    本系列博客所有Java代码都使用IntelliJ IDEA编译运行，版本为2022.1。所用JDK版本为JDK11。

    目录

    Stream流

    体验Stream流

    Stream流的使用

    Stream流的生成方式

    Stream流中间操作 filter

    Stream流中间操作 limit skip

    Stream流中间操作 concat distinct

    Stream流中间操作 sorted

    Stream流中间操作 map mapToInt

    Stream流终结操作 forEach count

    Stream流综合练习

    Stream流的收集操作

    Stream流

    体验Stream流

    Stream流把真正的函数式编程风格引入Java中。

    1. import java.util.ArrayList;
    2. public class stream1 {
    3.     public static void main(String[] args){
    4.         ArrayList list = new ArrayList();
    5.         list.add("Hilda");
    6.         list.add("Henri");
    7.         list.add("Howard");
    8.         list.add("Hermine");
    9.         list.add("Hilary");
    10.         list.add("Harvey");
    11.  
    12.         list.add("Hector");
    13.         list.add("Helene");
    14.         list.add("Henriette");
    15.         list.add("Humberto");
    16.         list.add("Hernan");
    17.         list.add("Hanna");
    18.  
    19.         list.stream().filter((String s) ->{
    20.             return (s.charAt(1) == 'e');
    21.         }).filter((String s) -> {
    22.             return s.length() ==6;
    23.         }).forEach((String s) ->{
    24.             System.out.println(s);
    25.         });
    26.     }
    27. }

    程序将列表中第二个字符是e，并且长度是6的字符串输出。程序的输出是：

    Hector
    Helene
    Hernan
     

    Stream流的使用

    生成流通过数据源（集合、数组等生成），如.stream()。

    一个流后面可以跟随多个中间操作，目的是打开流，做出某种程度的程序过滤/映射，然后返回一个新的流，交给下一个操作使用。如filter()。

    一个流只能有一个终结操作，执行后流就无法再操作，是流的最后一个操作，如forEach()。

    Stream流的生成方式

    Collection体系的集合可以使用默认方法stream()生成流。default Stream stream()

    Map体系的集合间接生成流。

    数组可以通过Stream接口的静态方法of(T...values)生成流。

    1. import java.util.HashMap;
    2. import java.util.List;
    3. import java.util.ArrayList;
    4. import java.util.stream.Stream;
    5. public class stream2 {
    6.     public static void main(String[] args){
    7.         List al = new ArrayList();
    8.         Stream s1 = al.stream();
    9.         Set hs = new HashSet();
    10.         Stream s2 = hs.stream();
    11.  
    12.         Map hm = new HashMap();
    13.         Stream s3 = hm.keySet().stream();
    14.         Stream s4 = hm.values().stream();
    15.         Stream> s5 = hm.entrySet().stream();
    16.  
    17.         String[] str = new String[]{"a","b","c","d"};
    18.         Stream s6 = Stream.of(str);
    19.     }
    20. }

    程序无输出。

    Stream流中间操作 filter

    Stream filter(Predicate predicate)对于流中的数据进行过滤。

    1. import java.util.ArrayList;
    2. public class streamfilter {
    3.     public static void main(String[] args){
    4.         ArrayList list = new ArrayList();
    5.         list.add("Hilda");
    6.         list.add("Henri");
    7.         list.add("Howard");
    8.         list.add("Hermine");
    9.         list.add("Hilary");
    10.         list.add("Harvey");
    11.  
    12.         list.add("Hector");
    13.         list.add("Helene");
    14.         list.add("Henriette");
    15.         list.add("Humberto");
    16.         list.add("Hernan");
    17.         list.add("Hanna");
    18.  
    19.         list.stream().filter((String s) ->{
    20.             return (s.charAt(1) == 'e');
    21.         }).forEach((String s) ->{
    22.             System.out.println(s);
    23.         });
    24.  
    25.         System.out.println();
    26.         list.stream().filter((String s) -> {
    27.             return s.length() ==6;
    28.         }).forEach((String s) ->{
    29.             System.out.println(s);
    30.         });
    31.     }
    32. }

    程序的输出是：

    Henri
    Hermine
    Hector
    Helene
    Henriette
    Hernan

    Howard
    Hilary
    Harvey
    Hector
    Helene
    Hernan

    Stream流中间操作 limit skip

    Stream limit(long maxSize)返回此流中的元素组成的流，截取前给定参数个数的数据。

    Stream skip(long n)跳过指定参数个数的数据，返回由该流的剩余元素组成的流。

    1. import java.util.ArrayList;
    2. public class streamlimitskip {
    3.     public static void main(String[] args){
    4.         ArrayList list = new ArrayList();
    5.         list.add("Hilda");
    6.         list.add("Henri");
    7.         list.add("Howard");
    8.         list.add("Hermine");
    9.         list.add("Hilary");
    10.         list.add("Harvey");
    11.  
    12.         list.add("Hector");
    13.         list.add("Helene");
    14.         list.add("Henriette");
    15.         list.add("Humberto");
    16.         list.add("Hernan");
    17.         list.add("Hanna");
    18.  
    19.         list.stream().limit(6).forEach((String s) ->{
    20.             System.out.println(s);
    21.         });
    22.         System.out.println();
    23.  
    24.         list.stream().skip(6).forEach((String s) ->{
    25.             System.out.println(s);
    26.         });
    27.         System.out.println();
    28.  
    29.         list.stream().skip(4).limit(4).forEach((String s) ->{
    30.             System.out.println(s);
    31.         });
    32.     }
    33. }

    程序的输出是：

    Hilda
    Henri
    Howard
    Hermine
    Hilary
    Harvey

    Hector
    Helene
    Henriette
    Humberto
    Hernan
    Hanna

    Hilary
    Harvey
    Hector
    Helene

    Stream流中间操作 concat distinct

    static Stream concat(Stream a,Stream b)合并a和b两个流为一个流。

    Stream distinct()返回该流的不同元素（根据Object.equals(Object)）组成的流。

    1. import java.util.ArrayList;
    2. import java.util.stream.Stream;
    3. public class streamconcatdistinct {
    4.     public static void main(String[] args){
    5.         ArrayList list = new ArrayList();
    6.         list.add("Hilda");
    7.         list.add("Henri");
    8.         list.add("Howard");
    9.         list.add("Hermine");
    10.         list.add("Hilary");
    11.         list.add("Harvey");
    12.  
    13.         list.add("Hector");
    14.         list.add("Helene");
    15.         list.add("Henriette");
    16.         list.add("Humberto");
    17.         list.add("Hernan");
    18.         list.add("Hanna");
    19.  
    20.         Stream s1 = list.stream().limit(10);
    21.         Stream s2 = list.stream().skip(2);
    22.         Stream.concat(s1,s2).forEach((String s)->{
    23.             System.out.print(s + "   ");
    24.         });
    25.         System.out.println();
    26.     }
    27. }

    程序的输出是：

    Hilda   Henri   Howard   Hermine   Hilary   Harvey   Hector   Helene   Henriette   Humberto   Howard   Hermine   Hilary   Harvey   Hector   Helene   Henriette   Humberto   Hernan   Hanna   
     

    1. import java.util.ArrayList;
    2. import java.util.stream.Stream;
    3. public class streamconcatdistinct {
    4.     public static void main(String[] args){
    5.         ArrayList list = new ArrayList();
    6.         list.add("Hilda");
    7.         list.add("Henri");
    8.         list.add("Howard");
    9.         list.add("Hermine");
    10.         list.add("Hilary");
    11.         list.add("Harvey");
    12.  
    13.         list.add("Hector");
    14.         list.add("Helene");
    15.         list.add("Henriette");
    16.         list.add("Humberto");
    17.         list.add("Hernan");
    18.         list.add("Hanna");
    19.  
    20.         Stream s1 = list.stream().limit(10);
    21.         Stream s2 = list.stream().skip(2);
    22.  
    23.         Stream.concat(s1,s2).distinct().forEach((String s)->{
    24.             System.out.print(s + "   ");
    25.         });
    26.         System.out.println();
    27.     }
    28. }

    程序的输出是：

    Hilda   Henri   Howard   Hermine   Hilary   Harvey   Hector   Helene   Henriette   Humberto   Hernan   Hanna   
     

    Stream流中间操作 sorted

    Stream sorted()返回此流的元素组成的流，根据自然排序排序。

    Stream sorted(Comparator comparator)返回此流的元素组成的流，根据提供的comparator排序。

    1. import java.util.ArrayList;
    2. import java.util.Comparator;
    3. public class streamsort {
    4.     public static void main(String[] args){
    5.         ArrayList list = new ArrayList();
    6.         list.add("Hilda");
    7.         list.add("Henri");
    8.         list.add("Howard");
    9.         list.add("Hermine");
    10.         list.add("Hilary");
    11.         list.add("Harvey");
    12.  
    13.         list.add("Hector");
    14.         list.add("Helene");
    15.         list.add("Henriette");
    16.         list.add("Humberto");
    17.         list.add("Hernan");
    18.         list.add("Hanna");
    19.  
    20.         list.stream().sorted().forEach((String s) ->{
    21.             System.out.print(s + "   ");
    22.         });
    23.         System.out.println();
    24.  
    25.         list.stream().sorted(new Comparator() {
    26.             public int compare(String s1,String s2){
    27.                 return s1.length() - s2.length();
    28.             }
    29.         }).forEach((String s) ->{
    30.             System.out.print(s + "   ");
    31.         });
    32.         System.out.println();
    33.     }
    34. }

    程序的输出是：

    Hanna   Harvey   Hector   Helene   Henri   Henriette   Hermine   Hernan   Hilary   Hilda   Howard   Humberto   
    Hilda   Henri   Hanna   Howard   Hilary   Harvey   Hector   Helene   Hernan   Hermine   Humberto   Henriette   

    Stream流中间操作 map mapToInt

    Stream map(Function mapper)返回给定函数应用于此流的元素的结果组成的流。

    IntStream mapToInt(ToIntFunction mapper)返回一个IntStream，其中包含将给定函数应用于此流的元素的结果。

    1. import java.util.ArrayList;
    2. public class streammapmaptoint {
    3.     public static void main(String[] args){
    4.         ArrayList list = new ArrayList();
    5.         list.add("10");
    6.         list.add("20");
    7.         list.add("30");
    8.         list.add("40");
    9.         list.add("50");
    10.  
    11.         list.stream().map((String s) ->{
    12.             return Integer.parseInt(s);
    13.         }).forEach((Integer i) -> {
    14.             System.out.println(i);
    15.         });
    16.         System.out.println();
    17.  
    18.         System.out.println(list.stream().mapToInt((String s) ->{
    19.             return Integer.parseInt(s);
    20.         }).sum());
    21.     }
    22. }

    程序的输出是：

    10
    20
    30
    40
    50

    150

    Stream流终结操作 forEach count

    void forEach(Consumer action)对此流的每个元素执行操作。

    long count()返回此流的元素数。

    1. import java.util.ArrayList;
    2. public class streamforeachcount {
    3.     public static void main(String[] args){
    4.         ArrayList list = new ArrayList();
    5.         list.add("Hilda");
    6.         list.add("Henri");
    7.         list.add("Howard");
    8.         list.add("Hermine");
    9.         list.add("Hilary");
    10.         list.add("Harvey");
    11.  
    12.         list.add("Hector");
    13.         list.add("Helene");
    14.         list.add("Henriette");
    15.         list.add("Humberto");
    16.         list.add("Hernan");
    17.         list.add("Hanna");
    18.  
    19.         list.stream().forEach((String s)->{
    20.             System.out.println(s);
    21.         });
    22.         System.out.println(list.stream().count());
    23.     }
    24. }

    程序的输出是：

    Hilda
    Henri
    Howard
    Hermine
    Hilary
    Harvey
    Hector
    Helene
    Henriette
    Humberto
    Hernan
    Hanna
    12
     

    Stream流综合练习

    1. public class actor {
    2.     private String name;
    3.     actor(){}
    4.     actor(String name){
    5.         this.name = name;
    6.     }
    7.  
    8.     public void setname(String name){
    9.         this.name = name;
    10.     }
    11.  
    12.     public String getname(){
    13.         return name;
    14.     }
    15. }

    这是actor类，有成员变量name。 

    1. import java.util.ArrayList;
    2. import java.util.stream.Stream;
    3. public class streamtest {
    4.     public static void main(String[] args){
    5.         ArrayList manlist = new ArrayList();
    6.         actor man1 = new actor("Peter");
    7.         actor man2 = new actor("Philippe");
    8.         actor man3 = new actor("Pablo");
    9.         actor man4 = new actor("Paine");
    10.         actor man5 = new actor("Paul");
    11.         actor man6 = new actor("Polo");
    12.         manlist.add(man1);
    13.         manlist.add(man2);
    14.         manlist.add(man3);
    15.         manlist.add(man4);
    16.         manlist.add(man5);
    17.         manlist.add(man6);
    18.  
    19.         ArrayList womanlist = new ArrayList();
    20.         actor woman1 = new actor("Paula");
    21.         actor woman2 = new actor("Patty");
    22.         actor woman3 = new actor("Paulette");
    23.         actor woman4 = new actor("Pamela");
    24.         actor woman5 = new actor("Pilar");
    25.         actor woman6 = new actor("Priscilla");
    26.         womanlist.add(woman1);
    27.         womanlist.add(woman2);
    28.         womanlist.add(woman3);
    29.         womanlist.add(woman4);
    30.         womanlist.add(woman5);
    31.         womanlist.add(woman6);
    32.  
    33.         Stream man = manlist.stream().filter((actor act)->{
    34.             return (act.getname().length() < 6);
    35.         }).limit(4);
    36.         Stream woman = womanlist.stream().filter((actor act)->{
    37.             return (act.getname().length() < 9);
    38.         }).skip(2);
    39.  
    40.         Stream people = Stream.concat(man,woman);
    41.         people.forEach((actor act)->{
    42.             System.out.println(act.getname());
    43.         });
    44.     }
    45. }

    程序创建了两个存储actor类对象的ArrayList集合，分别加入6个对象，随后按条件进行操作。

    程序的输出是：

    Peter
    Pablo
    Paine
    Paul
    Paulette
    Pamela
    Pilar

    Stream流的收集操作

    工具类Collectors提供了具体收集方式，把流中的数据收到集合中：

    public static Collector toList()将元素收集到List集合中。

    public static Collector toSet()将元素收集到Set集合中。

    public static Collector toMap(Function keyMapper,Function valueMapper)将元素收集到Map集合中。

    1. import java.util.ArrayList;
    2. import java.util.HashMap;
    3. import java.util.HashSet;
    4. import java.util.Set;
    5. import java.util.stream.Collectors;
    6. import java.util.stream.Stream;
    7. public class streamcollect {
    8.     public static void main(String[] args){
    9.         ArrayList strlist = new ArrayList();
    10.         strlist.add("Pamela");
    11.         strlist.add("Peter");
    12.         strlist.add("Paine");
    13.         strlist.add("Paula");
    14.         strlist.add("Pilar");
    15.         strlist.add("Philippe");
    16.  
    17.         strlist.add("Paul");
    18.         strlist.add("Patty");
    19.         strlist.add("Priscilla");
    20.         strlist.add("Pablo");
    21.         strlist.add("Polo");
    22.         strlist.add("Paulette");
    23.  
    24.         Stream s1 = strlist.stream().filter((String s)->{
    25.             return s.length() < 7;
    26.         });
    27.         ArrayList s1list = (ArrayList) s1.collect(Collectors.toList());
    28.         for(String s:s1list){
    29.             System.out.print(s + "   ");
    30.         }
    31.         System.out.println();
    32.  
    33.         HashSet intset = new HashSet();
    34.         intset.add(21);
    35.         intset.add(19);
    36.         intset.add(22);
    37.         intset.add(16);
    38.         intset.add(20);
    39.         intset.add(23);
    40.  
    41.         Stream s2 = intset.stream().filter((Integer i) ->{
    42.             return i > 18;
    43.         });
    44.  
    45.         HashSet s2set = (HashSet) s2.collect(Collectors.toSet());
    46.         for(Integer i:s2set){
    47.             System.out.println(i + "   ");
    48.         }
    49.         System.out.println();
    50.  
    51.         String[] strarr = new String[]{"Pamela,21","Peter,18","Paine,16","Paula,22","Pilar,15","Philippe,21",
    52.         "Paul,20","Patty,20","Priscilla,19","Pablo,23","Polo,18","Paulette,22"};
    53.         Stream s3 = Stream.of(strarr).filter((String s) ->{
    54.             return Integer.parseInt(s.split(",")[1]) > 18;
    55.         });
    56.  
    57.         HashMap s3map = (HashMap) s3.collect(Collectors.toMap((String s) ->{
    58.             return s.split(",")[0];
    59.         },(String s) ->{
    60.             return Integer.parseInt(s.split(",")[1]);
    61.         }));
    62.  
    63.         Set hs = s3map.keySet();
    64.         for(String s:hs){
    65.             System.out.println(s + s3map.get(s));
    66.         }
    67.     }
    68. }

    程序的输出是：

    Pamela   Peter   Paine   Paula   Pilar   Paul   Patty   Pablo   Polo   
    19   20   21   22   23   
    Pablo23
    Philippe21
    Pamela21
    Priscilla19
    Paulette22
    Paula22
    Paul20
    Patty20

  • 相关阅读:
    每一次只可跨1阶或2阶，爬100阶的楼梯可有多少种走法题解
    猿创征文｜11个开发者必备工具，赶快收藏
    如果报华为网络工程师中级培训班一般学费多少？
    Git多人协作场景的使用
    hadoop_虚拟机linux环境部署全教程
    Java毕业设计 JSP+MySQL幼儿园信息管理系统
    django-haystack使用小结
    从Github登录的双因子验证到基于时间戳的一次性密码：2FA、OTP与TOTP
    Jupyter介绍和安装使用
    （附源码）ssm航空客运订票系统 毕业设计 141612
  • 原文地址：https://blog.csdn.net/m0_71007572/article/details/126468088