JDK -- Stream使用

目录

Stream流的获取方式

Collection接口(List & Set)

Map接口

数组

中间方法

filter过滤

 limit前几个元素

Skip跳过前几个元素

distinct去除重复元素 -- 依赖hashcode和equals方法

max取最大值 

Sort排序

 Map对数据进行加工

contact 合并两个流为一个流

总结方法

forEach 遍历

count 元素个数

Collect 收集方法

toList 

toSet

toMap

---

JDK8 以后提供了Stream流来对集合进行处理，配合lambda表达式简化code，带来函数式编程

Stream流的核心思想:

1. 先得到集合或者数组的Stream流（就是一根传送带)
2. 把元素放上去
3. 然后就用这个Stream流简化的API来方便的操作元素。

Stream流可以分为三部分:

1. 获取Stream流
   --创建一条流水线，并把数据放到流水线上准备进行操作
2. 中间方法
   --流水线的操作，一次操作完毕后，还可以继续进行其他操作
3. 终结方法
   --一个Stream流只能有一个终结方法，是流水线上的最后一个操作

Stream流的获取方式

Collection接口(List & Set)

/** --------------------Collection集合获取流-------------------------------   */
Collection list = new ArrayList<>();
Stream stream =  list.stream();
Collection set = new HashSet<>();
Stream setStream = set.stream();

Map接口

/** --------------------Map集合获取流-------------------------------   */
Map maps = new HashMap<>();
// 键流
Stream keyStream = maps.keySet().stream();
// 值流
Stream valueStream = maps.values().stream();
// 键值对流（拿整体）
Stream> keyAndValueStream =  maps.entrySet().stream();

数组

/** ---------------------数组获取流------------------------------   */
String[] names = {"赵敏","小昭","灭绝","周芷若"};
Stream nameStream = Arrays.stream(names);
Stream nameStream2 = Stream.of(names);

中间方法

注意：

l 中间方法也称为非终结方法，调用完成后返回新的 Stream 流可以继续使用，支持链式编程。

l 在 Stream 流中无法直接修改集合、数组中的数据。

filter过滤

List list = new ArrayList<>();
Collections.addAll(list, "张无忌","周芷若","赵敏","张强","张三丰","张三丰");
 
// Stream filter(Predicate predicate)
list.stream().filter(s -> s.startsWith("张")).forEach(s -> System.out.println(s));
 
long size = list.stream().filter(s -> s.length() == 3).count();
System.out.println(size);

 limit前几个元素

// list.stream().filter(s -> s.startsWith("张")).limit(2).forEach(s -> System.out.println(s));
list.stream().filter(s -> s.startsWith("张")).limit(2).forEach(System.out::println);

Skip跳过前几个元素

list.stream().filter(s -> s.startsWith("张")).skip(2).forEach(System.out::println);

distinct去除重复元素 -- 依赖hashcode和equals方法

list.stream().filter(s -> s.startsWith("张")).distinct().forEach(s -> System.out.println(s));

max取最大值 

需要比较器 Comparator

List one = new ArrayList<>();
one.add(new Employee("猪八戒",'男',30000 , 25000, null));
one.add(new Employee("孙悟空",'男',25000 , 1000, "顶撞上司"));
one.add(new Employee("沙僧",'男',20000 , 20000, null));
one.add(new Employee("小白龙",'男',20000 , 25000, null));
 
Employee e = one.stream().max((e1, e2) -> Double.compare(e1.getSalary() + e1.getBonus(),  e2.getSalary() + e2.getBonus())).get();

Sort排序

需要比较器 Comparator

List one = new ArrayList<>();
one.add(new Employee("猪八戒",'男',30000 , 25000, null));
one.add(new Employee("孙悟空",'男',25000 , 1000, "顶撞上司"));
one.add(new Employee("沙僧",'男',20000 , 20000, null));
one.add(new Employee("小白龙",'男',20000 , 25000, null));
 
one.stream().sorted((e1, e2) -> Double.compare(e1.getSalary() + e1.getBonus(),  e2.getSalary() + e2.getBonus()))
		.forEach(s -> System.out.println(s));

 Map对数据进行加工

参数为Function

List list = new ArrayList<>();
Collections.addAll(list, "张无忌","张三丰","赵敏","小昭","张强");
list.stream().map(new Function() {
	@Override
	public String apply(String s) {
		return "黑马的：" + s;
	}
}).forEach(System.out::println);
//等同于上面, lambda简写格式
list.stream().map(s -> "黑马的：" + s).forEach(a -> System.out.println(a));
//相当于Function
list.stream().map(s -> new Student(s)).forEach(s -> System.out.println(s));
//上一行的简化格式
list.stream().map(Student::new).forEach(System.out::println);

contact 合并两个流为一个流

Stream s1 = list.stream().filter(s -> s.startsWith("张"));
Stream s2 = Stream.of("java1", "java2");
// public static  Stream concat(Stream a, Stream b)
Stream s3 = Stream.concat(s1 , s2);

总结方法

注意：终结操作方法，调用完成后流就无法继续使用了，原因是不会返回Stream了。

forEach 遍历

​
List list = new ArrayList<>();
Collections.addAll(list, "张无忌","周芷若","赵敏","张强","张三丰","张三丰");
 
// Stream filter(Predicate predicate)
list.stream().filter(s -> s.startsWith("张")).forEach(s -> System.out.println(s));
 
 
​

count 元素个数

List list = new ArrayList<>();
Collections.addAll(list, "张无忌","周芷若","赵敏","张强","张三丰","张三丰");
 
long size = list.stream().filter(s -> s.length() == 3).count();
System.out.println(size);

Collect 收集方法

toList 

List list = new ArrayList<>();
Collections.addAll(list, "张无忌","周芷若","赵敏","张强","张三丰","张三丰");
 
Stream s1 = list.stream().filter(s -> s.startsWith("张"));
List zhangList = s1.collect(Collectors.toList()); // 可变集合

toSet

List list = new ArrayList<>();
Collections.addAll(list, "张无忌","周芷若","赵敏","张强","张三丰","张三丰");
 
// 注意注意注意：“流只能使用一次”
Set zhangSet = list.stream().filter(s -> s.startsWith("张"))
        .collect(Collectors.toSet());
System.out.println(zhangSet);

toMap

 例如将List 转为 Map

public static void main(String[] args) {
	List list = new ArrayList<>();
	Collections.addAll(list,
			new Student(1, "张三"),
			new Student(2, "李四"),
			new Student(1, "王五"));
 
	Map map =
			list.stream().collect(
					Collectors.toMap(Student::getId, Student::getName, (v1, v2) -> v1));
 
	System.out.println(map);
}

结果如下:

{1=张三, 2=李四}

toMap时只用到两个参数，第一个设定Key，第二个设定value。但如果Key重复的话，那就需要用到第三个参数，可以这么写（v1, v2）-> v1, 当key重复时使用之前的，如果是(v1,v2) -> v2，则表示覆盖