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