Stream流
Stream流
:
- Stream流结合了Lambda表达式,简化了集合、数组的操作。
- ①使用步骤:
- ①得到一条
Stream流
,并将数据放上去。 - ②使用
中间方法
对流水线上的数据进行操作。 - ③使用
终结方法
对流水线上的数据进行操作。 - 小案例:
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两个函数式接口,需要编写匿名内部类,重写方法,指定数据转换规则。
- 案例:
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())); } }