八、Stream接口
8.1 创建Stream
//Stream可以将任意对象转换为一个流,这个Stream<>是个泛型接口。
Collection<T>接口下有default stream()方法,可以把任何集合向上转型为Collection然后转为Stream。
Stream parallelStream()顺序流或者并行流
Stream.of(obj...可变长参数)。
Arrays.stream(array,from,to)从数组的from(包括)到to(不包括)的元素中创建一个流
Stream.concat(Stream<T> a,Stream<T> b):产生一个流,它的元素是a后面跟着b的元素(拼接两个流)。
Stream.empty()创建一个空的流
Stream.generate(Supplier<T> s)产生一个无限流,元素无限,它的值是通过反复调用函数s创建的
Stream.iterate(T seed,UnaryOperator<T> function):产生一个无限流,元素无限,seed是初始化种子(值),它的第一个元素是function作用在seed上的结果,后面的每个元素是function作用在前一个元素的结果。
如:Stream.iterate(2, new UnaryOperator<Integer>() {
@Override
public Integer apply(Integer integer) {
return integer*2;
}
}).limit(10).forEach(System.out::println);
Pattern.splitAsStream(Charsequence input)产生一个流,它的元素是输入中由该模式定界的部分。正则表达式匹配的对象(Pattern p = Pattern.compile(String regex))
8.2 实例方法
以下返回了新的流的方法,都会使原来的流关闭,如果操作原来的流会报异常。(流转换)
int count():返回流对象中的个数,这是一个终止操作,会关闭流
Stream filter(predicate<T>接口(test方法)):匹配任何符合条件的对象,把他们放到新的Stream中,返回Stream<obj>对象
Stream map(function<T>接口(apply方法)):匹配每一个对象,执行方法,返回同样元素个数的Stream对象
Stream limit(int n):抽取子流,n表示抽取的流中抽取前n个元素作为流返回
Stream skip(int n):跳过子流,n表示跳过流中多少部分,将剩下的元素作为流返回
Stream forEach(Consumer<T> action):遍历元素,执行自定义的操作,可以引用函数
如:Stream.generate(new Supplier<Integer>() {
@Override
public Integer get() {
return ThreadLocalRandom.current().nextInt(10);
}
}).limit(10).forEach(System.out::println);
Stream distinct():去重,去重后会关闭原来的流,返回一个新的流。
Stream sorted():默认无参是按照数值升序,字母表顺序排列,返回一个新的流,如果是自定义对象,则按照实现的Comparable接口的compareTo方法排序。
Stream sorted(Comparotor<T>):按照传入的Comparator比较器的compare方法排序
Stream peek(Consumer<T> action):返回一个元素和原来的流一模一样的流,但是以后获取新的流的每个元素时,会将其传递给action,action也会被执行。
Stream findFirst():找到非空集合的第一个值,通常和filter搭配。
Stream findAny():找到非空集合的任意一个值,通常和filter搭配。
Stream max(Comparator<T> action):找到给定比较规则的最大值
Stream min(Comparator<T> action):找到给定比较规则的最小值
boolean anyMatch(Predicate<T> test):只要有任何一个满足test,就返回true
boolean allMatch(Predicate<T> test):所有都满足test,才返回true
boolean noneMatch(Predicate<T> test):一个都不满足test,才返回true
Iterator<T> iterator():获得一个迭代器
8.3 Optional类
- 这是一种包装类型<T>,类似装箱,来替代T的引用OptionalInt o = OptionalInt.of(Object obj); //包装为Optional
boolean equals(10); //判断是否相等
int getAsInt(); //获得value
boolean isPresent(); //判断是否存在
orElse(T t);//如果不存在就替换,如果存在就返回value
Optional.empty():产生一个空的Optional
o.ifPresent(new IntConsumer() { //判断是否存在,如果存在就执行accept方法
@Override
public void accept(int value) {
System.out.println(o.getAsInt());
}
});
o.orElseGet(new IntSupplier() { //如果不存在就执行getAsInt方法,如果存在就返回value
@Override
public int getAsInt() {
return 40;
}
});
o.orElseThrow(new Supplier<Throwable>() { //如果存在就返回value,如果不存在就抛出异常
@Override
public Throwable get() {
return new RuntimeException("no such value");
}
});