Java8中的Stream
Stream使用一种类似用SQL语句从数据库查询数据的直观方式来提供一种对Java集合运算和表达的高阶抽象.
Stream的特性及优点:
- 无存储. Stream不是一种数据结构,它只是某种数据源的一个视图,数据源可以是一个数组,Java容器或I/O channel等.
- 为函数式编程而生. 对于Stream的任何修改都不会修改背后的数据源,比如对Stream执行过滤操作并不会删除被过滤的元素,而是会产生一个不包含被过滤掉元素的新Stream
- 惰式执行: Stream上的操作不回立即执行,只有等到用户真正需要结果的时候才会执行.
- 可消费性: Stream只能被消费一次,一旦遍历过后就会失效,就像容器的迭代器一样,想要再次遍历必须重新生成.
Stream的创建
- 通过已有的集合来创建流:
通过集合的stream方法来创建流
// 数组
String[] s = "I Love You But I miss You so I miss you".split(" ");
Stream<String> stream = Arrays.stream(s);
// 集合
List<String> list = Arrays.asList(s);
Stream<String> stream1 = list.stream();
- 通过Stream创建流
Stream类提供了of静态方法来创建Stream流
Stream<String> stringStream = Stream.of("1", "2", "3");
Stream流常用的中间操作
filter
filter方法用于通过设置的条件过滤出元素,下面的例子是过滤出长度大于3的字符串
String[] s = "I Love You But I miss You so I miss you".split(" ");
List<String> list = Arrays.asList(s);
// 流转List
list.stream().filter(str -> str.length() > 3);
map
map元素用于映射每隔元素到对应的结果,下面的例子用map输出元素对应的平方数
Stream.of(1,2,3,4,5).map(i -> i * i).forEach(System.out::println);
limit / skip
limit是返回Stream的前面n个元素;skip是跳过前面n个元素.下面的例子是保留前四个元素:
Stream.of(1,2,3,4,5).limit(4).forEach(System.out::println);
sorted
sorted方法是用于对流进行排序.下面例子是进行排序
// 默认是从小到大
Stream.of(5,4,3,2,1).sorted().forEach(System.out::println);
// 重写比较器方法从大到小
Stream.of(1,2,3,4,5).sorted((x,y)-> {return y - x;}).forEach(System.out::println);
distinct
distinct主要用来去重,下面的例子是用来去重的
// 去重
Stream.of(5,4,3,5,4).distinct().forEach(System.out::println);
注意上面操作的返回结果还是Stream流,这个意思也就是可以进行流式操作,直到遇到最终操作,下面就说一下最终操作.
最终操作
最终操作就是一些输出,统计,转换等操作,返回结果不再是Stream流. 但是注意的是当进行最终操作之后,不可再次使用流,否则会抛出异常.
java.lang.IllegalStateException: stream has already been operated upon or closed
forEach
Stream利用forEach来迭代流中的数据,下面的代码片段使用forEach输出10个随机数
Random random = new Random();
random.ints().limit(10).forEach(System.out::println);
count
count方法是用来统计流中元素的个数
Stream.of(5,4,3,5,4).count();
collect
collect方法是一个规约操作,就是将结果进行转换为集合或者其他. 下面的例子是将流转化为集合.
Stream.of(5,4,3,5,4).collect(Collectors.toList());
当然其中还有很多方法,比如说reduce(累计求和),flatMap等等方法,源码路径为: java.util.stream.Stream