Stream
概述
Stream 流其实就是一根传送带,元素在上面可以被 Stream 流操作
- 可以解决已有集合类库或者数组 API 的弊端
- Stream 流简化集合和数组的操作
- 链式编程
list.stream().filter(new Predicate<String>() { @Override public boolean test(String s) { return s.startsWith("张"); } }); list.stream().filter(s -> s.startsWith("张"));
获取流
集合获取 Stream 流用:default Stream<E> stream()
数组:Arrays.stream(数组) / Stream.of(数组);
// Collection集合获取Stream流。 Collection<String> c = new ArrayList<>(); Stream<String> listStream = c.stream(); // Map集合获取流 // 先获取键的Stream流。 Stream<String> keysStream = map.keySet().stream(); // 在获取值的Stream流 Stream<Integer> valuesStream = map.values().stream(); // 获取键值对的Stream流(key=value: Map.Entry<String,Integer>) Stream<Map.Entry<String,Integer>> keyAndValues = map.entrySet().stream(); //数组获取流 String[] arr = new String[]{"Java", "JavaEE" ,"Spring Boot"}; Stream<String> arrStream1 = Arrays.stream(arr); Stream<String> arrStream2 = Stream.of(arr);
常用API
方法名 | 说明 |
void forEach(Consumer<? super T> action) | 逐一处理(遍历) |
long count | 返回流中的元素数 |
Stream filter(Predicate<? super T> predicate) | 用于对流中的数据进行过滤 |
Stream limit(long maxSize) | 返回此流中的元素组成的流,截取前指定参数个数的数据 |
Stream skip(long n) | 跳过指定参数个数的数据,返回由该流的剩余元素组成的流 |
Stream map(Function<? super T,? extends R> mapper) | 加工方法,将当前流中的 T 类型数据转换为另一种 R 类型的流 |
static Stream concat(Stream a, Stream b) | 合并 a 和 b 两个流为一个,调用 Stream.concat(s1,s2) |
Stream distinct() | 返回由该流的不同元素组成的流 |
终结方法
终结方法:Stream 调用了终结方法,流的操作就全部终结,不能继续使用,如 foreach,count 方法等
非终结方法:每次调用完成以后返回一个新的流对象,可以继续使用,支持链式编程
// foreach终结方法 list.stream().filter(s -> s.startsWith("张")) .filter(s -> s.length() == 3).forEach(System.out::println);
收集流
收集 Stream:把 Stream 流的数据转回到集合中去
- Stream 流:工具
- 集合:目的
Stream 收集方法:R collect(Collector collector)
把结果收集到集合中
Collectors 方法:
public static <T> Collector toList()
:把元素收集到 List 集合中public static <T> Collector toSet()
:把元素收集到 Set 集合中public static Collector toMap(Function keyMapper,Function valueMapper)
:把元素收集到 Map 集合中Object[] toArray()
:把元素收集数组中public static Collector groupingBy(Function<? super T, ? extends K> classifier)
:分组+