Stream流终结操作方法、收集操作及Stream综合练习

野性酷女 2024-04-06 10:18 71阅读 0赞

**目录**

一、Stream流终结操作方法

二、Stream流的收集操作

三、Stream流综合练习

--------------------

## 一、Stream流终结操作方法 ##

概念：终结操作的意思，就是执行完此方法之后，Stream流将不能再执行其他操作

常见方法：

<table style="width:500px;"> 
 <tbody> 
  <tr> 
   <td>方法名</td> 
   <td>说明</td> 
  </tr> 
  <tr> 
   <td>void forEach(Consume action)</td> 
   <td>对此流的每个元素执行操作</td> 
  </tr> 
  <tr> 
   <td>long count()</td> 
   <td>返回此流中的元素数</td> 
  </tr> 
 </tbody> 
</table>

代码演示：

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("张启天");
    
            //需求1：把集合中的元素在控制台输出 
            list.stream().forEach(System.out::println); 
    
            //需求2：统计集合中有几个以张开头的元素，并把统计结果在控制台输出 
            long count = list.stream().filter(s -> s.startsWith("张")).count();
            System.out.println(count);
        }
    }

## 二、Stream流的收集操作 ##

概念：对数据使用Stream流的方式操作完毕后，可以把流中的数据收集到集合中

常用方法：

<table style="width:500px;"> 
 <tbody> 
  <tr> 
   <td>方法名</td> 
   <td>说明</td> 
  </tr> 
  <tr> 
   <td>R collect(Collector collector)</td> 
   <td>把结果收集到集合中</td> 
  </tr> 
 </tbody> 
</table>

工具类Collectors提供了具体的收集方式：

<table style="width:500px;"> 
 <tbody> 
  <tr> 
   <td>方法名</td> 
   <td>说明</td> 
  </tr> 
  <tr> 
   <td>public static Collector toList()</td> 
   <td>把元素收集到List集合中</td> 
  </tr> 
  <tr> 
   <td>public static Collector toSet()</td> 
   <td>把元素收集到Set集合中</td> 
  </tr> 
  <tr> 
   <td>public static Collector toMap(Function keyMapper,Function valueMapper)</td> 
   <td>把元素收集到Map集合中</td> 
  </tr> 
 </tbody> 
</table>

代码演示：

public class CollectDemo {
        public static void main(String[] args) {
            //创建List集合对象 
            List<String> list = new ArrayList<String>();
    
            list.add("孙悟空");
            list.add("孙行者");
            list.add("王宝强");
            list.add("柳神"); 
    
            //需求1：得到名字为3个字的流 
            Stream<String> listStream = list.stream().filter(s -> s.length() == 3); 
            //需求2：把使用Stream流操作完毕的数据收集到List集合中并遍历 
            List<String> names = listStream.collect(Collectors.toList()); 
            for(String name : names) { 
            System.out.println(name); 
            }
    
            //创建Set集合对象 
            Set<Integer> set = new HashSet<Integer>();
            set.add(10);
            set.add(20);
            set.add(30);
            set.add(33);
            set.add(35); 
    
            //需求3：得到年龄大于25的流 
            Stream<Integer> setStream = set.stream().filter(age -> age > 25); 
    
            //需求4：把使用Stream流操作完毕的数据收集到Set集合中并遍历 
            Set<Integer> ages = setStream.collect(Collectors.toSet()); 
            for(Integer age : ages) { 
                System.out.println(age); 
            }
    
            //定义一个字符串数组，每一个字符串数据由姓名数据和年龄数据组合而成 
            String[] strArray = {"孙悟空,560", "孙行者,555", "王宝强,33", "柳神,22"};
    
            //需求5：得到字符串中年龄数据大于28的流 
            Stream<String> arrayStream = Stream.of(strArray).filter(s -> Integer.parseInt(s.split(",")[1]) > 28);
    
            //需求6：把使用Stream流操作完毕的数据收集到Map集合中并遍历，字符串中的姓名作键，年龄作值 
            Map<String, Integer> map = arrayStream.collect(Collectors.toMap(s -> s.split(",")[0], s -> Integer.parseInt(s.split(",")[1])));
    
            Set<String> keySet = map.keySet();
            for (String key : keySet) {
                Integer value = map.get(key);
                System.out.println(key + "," + value);
            }
        }
    }

## 三、Stream流综合练习 ##

需求：

现在有两个ArrayList集合，分别存储6名男演员名称和6名女演员名称，要求完成如下操作：

> 男演员只要名字为3个字的前三人
> 
> 女演员只要姓林的，并且不要第一个
> 
> 把过滤后的男演员姓名和女演员姓名合并到一起
> 
> 把上一步操作后的元素作为构造方法的参数创建演员对象，遍历数据

代码实现：

public class Actor {
        private String name;
    
        public Actor(String name) {
            this.name = name;
        }
    
        public String getName() {
            return name;
        }
    
        public void setName(String name) {
            this.name = name;
        }
    }
    
    public class StreamTest {
        public static void main(String[] args) {
            //创建集合 
            ArrayList<String> manList = new ArrayList<String>();
            manList.add("周润发");
            manList.add("成龙");
            manList.add("刘德华");
            manList.add("吴京");
            manList.add("周星驰");
            manList.add("李连杰");
    
            ArrayList<String> womanList = new ArrayList<String>();
            womanList.add("林心如");
            womanList.add("张曼玉");
            womanList.add("林青霞");
            womanList.add("柳岩");
            womanList.add("林志玲");
            womanList.add("王祖贤"); 
    
            //男演员只要名字为3个字的前三人
            Stream<String> manStream = manList.stream().filter(s -> s.length() == 3).limit(3); 
    
            //女演员只要姓林的，并且不要第一个 
            Stream<String> womanStream = womanList.stream().filter(s -> s.startsWith("林")).skip(1); 
    
            //把过滤后的男演员姓名和女演员姓名合并到一起 
            Stream<String> stream = Stream.concat(manStream, womanStream); 
    
            //把上一步操作后的元素作为构造方法的参数创建演员对象,遍历数据 
            // stream.map(Actor::new).forEach(System.out::println); 
            stream.map(Actor::new).forEach(p -> System.out.println(p.getName())); 
    
            //把以上操作联合在一起
            Stream.concat(manList.stream().filter(s -> s.length() == 3).limit(3), womanList
                .stream().filter(s -> s.startsWith("林")).skip(1)).map(Actor::new)
                .forEach(p -> System.out.println(p.getName()));
        }    
    }