目录
概念:终结操作的意思,就是执行完此方法之后,Stream流将不能再执行其他操作
常见方法:
方法名 | 说明 |
void forEach(Consume action) | 对此流的每个元素执行操作 |
long count() | 返回此流中的元素数 |
代码演示:
- public class StreamDemo {
- public static void main(String[] args) {
- //创建一个集合,存储多个字符串元素
- ArrayList
list = new ArrayList(); -
- 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流的方式操作完毕后,可以把流中的数据收集到集合中
常用方法:
方法名 | 说明 |
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
list = new ArrayList(); -
- list.add("孙悟空");
- list.add("孙行者");
- list.add("王宝强");
- list.add("柳神");
-
- //需求1:得到名字为3个字的流
- Stream
listStream = list.stream().filter(s -> s.length() == 3); - //需求2:把使用Stream流操作完毕的数据收集到List集合中并遍历
- List
names = listStream.collect(Collectors.toList()); - for(String name : names) {
- System.out.println(name);
- }
-
- //创建Set集合对象
- Set
set = new HashSet(); - set.add(10);
- set.add(20);
- set.add(30);
- set.add(33);
- set.add(35);
-
- //需求3:得到年龄大于25的流
- Stream
setStream = set.stream().filter(age -> age > 25); -
- //需求4:把使用Stream流操作完毕的数据收集到Set集合中并遍历
- Set
ages = setStream.collect(Collectors.toSet()); - for(Integer age : ages) {
- System.out.println(age);
- }
-
- //定义一个字符串数组,每一个字符串数据由姓名数据和年龄数据组合而成
- String[] strArray = {"孙悟空,560", "孙行者,555", "王宝强,33", "柳神,22"};
-
- //需求5:得到字符串中年龄数据大于28的流
- Stream
arrayStream = Stream.of(strArray).filter(s -> Integer.parseInt(s.split(",")[1]) > 28); -
- //需求6:把使用Stream流操作完毕的数据收集到Map集合中并遍历,字符串中的姓名作键,年龄作值
- Map
map = arrayStream.collect(Collectors.toMap(s -> s.split(",")[0], s -> Integer.parseInt(s.split(",")[1]))); -
- Set
keySet = map.keySet(); - for (String key : keySet) {
- Integer value = map.get(key);
- System.out.println(key + "," + value);
- }
- }
- }
需求:
现在有两个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
manList = new ArrayList(); - manList.add("周润发");
- manList.add("成龙");
- manList.add("刘德华");
- manList.add("吴京");
- manList.add("周星驰");
- manList.add("李连杰");
-
- ArrayList
womanList = new ArrayList(); - womanList.add("林心如");
- womanList.add("张曼玉");
- womanList.add("林青霞");
- womanList.add("柳岩");
- womanList.add("林志玲");
- womanList.add("王祖贤");
-
- //男演员只要名字为3个字的前三人
- Stream
manStream = manList.stream().filter(s -> s.length() == 3).limit(3); -
- //女演员只要姓林的,并且不要第一个
- Stream
womanStream = womanList.stream().filter(s -> s.startsWith("林")).skip(1); -
- //把过滤后的男演员姓名和女演员姓名合并到一起
- Stream
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()));
- }
- }