Stream流终结操作方法、收集操作及Stream综合练习-蒲公英云

一、Stream流终结操作方法

二、Stream流的收集操作

三、Stream流综合练习

一、Stream流终结操作方法

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

常见方法：

方法名	说明
void forEach(Consume action)	对此流的每个元素执行操作
long count()	返回此流中的元素数

代码演示：

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流的方式操作完毕后，可以把流中的数据收集到集合中

常用方法：

方法名	说明
R collect(Collector collector)	把结果收集到集合中

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

方法名	说明
public static Collector toList()	把元素收集到List集合中
public static Collector toSet()	把元素收集到Set集合中
public static Collector toMap(Function keyMapper,Function valueMapper)	把元素收集到Map集合中

代码演示：

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()));
    }    
}