Stream流
Stream流
:
Stream流结合了Lambda表达式,简化了集合、数组的操作。
①使用步骤:
①得到一条Stream流
,并将数据放上去。
②使用中间方法
对流水线上的数据进行操作。
③使用终结方法
对流水线上的数据进行操作。
小案例:
代码语言:javascript复制import java.util.ArrayList;
public class StreamDemo {
public static void main(String[] args) {
/*
* 创建集合、添加元素,使用Stream流,
* ①将开头为“张”的元素添加进新集合
* ②之后将长度为3的元素添加进新集合
* ③遍历
*/
ArrayList<String> list = new ArrayList<>();
list.add("张三丰");
list.add("张无忌");
list.add("张强");
list.add("王麻子");
list.add("小李");
//获取对象stream流,添加过滤条件,遍历
list.stream()
.filter(name -> name.startsWith("张"))
.filter(name -> name.length() == 3)
.forEach(name -> System.out.println(name));
}
}
②获取Stream流:
default Stream<E> stream()
:单列集合获取Stream流(Collection的默认方法)public static <T> Stream<T> stream(T[] array)
:数组获取Stream流(Arrays工具类中的静态方法)public static <T> stream<T> of(T... values)
:获取一堆零散数据的Stream流(Stream接口中的静态方法,数据需要统一类型)- 双列集合无法直接获取Stream流,需要先使用
keySet() / entrySet()
再对获取到的集合使用stream()
获取。
③Stream流中间方法:
Stream<T> filter(Predicate<? super T> predicate)
:过滤Stream<T> limit(long maxSize)
:Stream流获取前maxSize个元素Stream<T> skip(long n)
:跳过前n个元素获取元素Stream<T> distance()
:元素去重,依赖HashCode() 和 equals()static <T> Stream<T> concat(Stream a,Stream b)
:将两个流合并为一个流Stream<R> map(Function<T,R> mapper)
:转换流中的数据类型,参数是函数式的,需重写其方法以设置转换规则,泛型依次是原本类型,转换的类型。-
- 中间方法、返回新的Stream流,流只能使用一次,建议链式编程。
- 修改Stream流中的数据,原本集合或数组的数据不变。
④Stream流的终结方法:
void forEach(Consumer action)
:遍历
long count()
:统计
toArray()
:将流中的数据放入数组
collect(Collector collector)
:将流中的数据放入集合
- Collectors.toList()
- Collectors.toSet()
- Collectors.toMap(a,b):a,b两个函数式接口,需要编写匿名内部类,重写方法,指定数据转换规则。
案例:
代码语言:javascript复制import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
import java.util.Map;
import java.util.stream.Collector;
import java.util.stream.Collectors;
public class StreamDemo {
public static void main(String[] args) {
/*定义集合,添加数据,留下偶数*/
ArrayList<Integer> listInt = new ArrayList<>();
Collections.addAll(listInt, 1,2,3,4,5,6,7,8,9,10);
listInt.stream().filter(s -> s.intValue() % 2 == 0).forEach(i -> System.out.println(i));
System.out.println("-------------------------------");
/*定义集合,添加姓名,年龄数据,保留年龄大于24的人,数据存入Map集合*/
ArrayList<String> listName = new ArrayList<>();
Collections.addAll(listName, "张三,18","李四,24","小品,24","小豪,29","张无忌,16","脉哦,22");
Map<String,Integer> mapName = listName.stream()
.filter(s -> Integer.parseInt(s.split(",")[1]) >= 24)
.collect(Collectors.toMap(
s -> s.split(",")[0] ,
s -> Integer.parseInt(s.split(",")[1])));
mapName.entrySet().forEach(s -> System.out.println(s.getKey() "--" s.getValue()));
}
}