Java8的Stream流(一) --- 基础用法

Java8中的Stream

Stream使用一种类似用SQL语句从数据库查询数据的直观方式来提供一种对Java集合运算和表达的高阶抽象.

Stream的特性及优点:

• 无存储. Stream不是一种数据结构,它只是某种数据源的一个视图,数据源可以是一个数组,Java容器或I/O channel等.
• 为函数式编程而生. 对于Stream的任何修改都不会修改背后的数据源,比如对Stream执行过滤操作并不会删除被过滤的元素,而是会产生一个不包含被过滤掉元素的新Stream
• 惰式执行: Stream上的操作不回立即执行,只有等到用户真正需要结果的时候才会执行.
• 可消费性: Stream只能被消费一次,一旦遍历过后就会失效,就像容器的迭代器一样,想要再次遍历必须重新生成.

Stream的创建

1. 通过已有的集合来创建流:

通过集合的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();

2. 通过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