你可能没意识到 Java 对函数式编程的重视程度,看看 Java 8 加入函数式编程扩充多少功能就清楚了。Java 8 之所以费这么大功夫引入函数式编程,原因有二:
方法。
- parallel()
这一节我们学习,也就是 Java 函数式编程的主角。对于 Java 7 来说完全是个陌生东西,并不是某种数据结构,它只是数据源的一种视图。这里的数据源可以是一个数组,Java 容器或 I/O channel 等。正因如此要得到一个通常不会手动创建,而是调用对应的工具方法,比如:
或者
- Collection.stream()
方法
- Collection.parallelStream()
方法
- Arrays.stream(T[] array)
常见的接口继承关系如图:
图中 4 种接口继承自
,其中
- BaseStream
对应三种基本类型(
- IntStream, LongStream, DoubleStream
,注意不是包装类型),
- int, long, double
对应所有剩余类型的视图。为不同数据类型设置不同接口,可以 1. 提高性能,2. 增加特定接口函数。
- Stream
你可能会奇怪为什么不把
等设计成
- IntStream
的子接口?毕竟这接口中的方法名大部分是一样的。答案是这些方法的名字虽然相同,但是返回类型不同,如果设计成父子接口关系,这些方法将不能共存,因为 Java 不允许只有返回类型不同的方法重载。
- Stream
虽然大部分情况下是容器调用
方法得到的,但和有以下不同:
- Collection.stream()
对的操作分为为两类,中间操作 () 和结束操作(),二者特点是:
如果你熟悉 Apache Spark RDD,对的这个特点应该不陌生。
下表汇总了
接口的部分常见方法:
- Stream
操作类型 | 接口方法 |
---|---|
中间操作 | concat() distinct() filter() flatMap() limit() map() peek() skip() sorted() parallel() sequential() unordered() |
结束操作 | allMatch() anyMatch() collect() count() findAny() findFirst() forEach() forEachOrdered() max() min() noneMatch() reduce() toArray() |
区分中间操作和结束操作最简单的方法,就是看方法的返回值,返回值为的大都是中间操作,否则是结束操作。
跟函数接口关系非常紧密,没有函数接口就无法工作。回顾一下:函数接口是指内部只有一个抽象方法的接口。通常函数接口出现的地方都可以使用 Lambda 表达式,所以不必记忆函数接口的名字。
我们对
方法并不陌生,在
- forEach()
中我们已经见过。方法签名为
- Collection
,作用是对容器中的每个元素执行
- void forEach(Consumer<? super E> action)
指定的动作,也就是对元素进行遍历。
- action
- // 使用Stream.forEach()迭代
- Stream stream = Stream.of("I", "love", "you", "too");
- stream.forEach(str -> System.out.println(str));
由于
是结束方法,上述代码会立即执行,输出所有字符串。
- forEach()
函数原型为
,作用是返回一个只包含满足
- Stream<T> filter(Predicate<? super T> predicate)
条件元素的
- predicate
。
- Stream
- // 保留长度等于3的字符串
- Stream stream= Stream.of("I", "love", "you", "too");
- stream.filter(str -> str.length()==3)
- .forEach(str -> System.out.println(str));
上述代码将输出为长度等于 3 的字符串
和
- you
。注意,由于
- too
是个中间操作,如果只调用
- filter()
不会有实际计算,因此也不会输出任何信息。
- filter()
函数原型为
,作用是返回一个去除重复元素之后的
- Stream<T> distinct()
。
- Stream
- Stream stream= Stream.of("I", "love", "you", "too", "too");
- stream.distinct()
- .forEach(str -> System.out.println(str));
上述代码会输出去掉一个
之后的其余字符串。
- too
排序函数有两个,一个是用自然顺序排序,一个是使用自定义比较器排序,函数原型分别为
和
- Stream<T>sorted()
。
- Stream<T>sorted(Comparator<? super T> comparator)
- Stream stream= Stream.of("I", "love", "you", "too");
- stream.sorted((str1, str2) -> str1.length()-str2.length())
- .forEach(str -> System.out.println(str));
上述代码将输出按照长度升序排序后的字符串,结果完全在预料之中。
函数原型为
,作用是返回一个对当前所有元素执行执行
- <R> Stream<R> map(Function<? super T,? extends R> mapper)
之后的结果组成的
- mapper
。直观的说,就是对每个元素按照某种操作进行转换,转换前后
- Stream
中元素的个数不会改变,但元素的类型取决于转换之后的类型。
- Stream
- Stream stream= Stream.of("I", "love", "you", "too");
- stream.map(str -> str.toUpperCase())
- .forEach(str -> System.out.println(str));
上述代码将输出原字符串的大写形式。
函数原型为
,作用是对每个元素执行
- <R> Stream<R> flatMap(Function<? super T,? extends Stream<? extends R>> mapper)
指定的操作,并用所有
- mapper
返回的
- mapper
中的元素组成一个新的
- Stream
作为最终返回结果。说起来太拗口,通俗的讲
- Stream
的作用就相当于把原中的所有元素都 "摊平" 之后组成的
- flatMap()
,转换前后元素的个数和类型都可能会改变。
- Stream
- Stream> stream = Stream.of(Arrays.asList(1,2), Arrays.asList(3, 4, 5));
- stream.flatMap(list -> list.stream())
- .forEach(i -> System.out.println(i));
上述代码中,原来的
中有两个元素,分别是两个
- stream
,执行
- List<Integer>
之后,将每个
- flatMap()
都 "摊平" 成了一个个的数字,所以会新产生一个由 5 个数字组成的
- List
。所以最终将输出 1~5 这 5 个数字。
- Stream
截止到目前我们感觉良好,已介绍
API 理解起来并不费劲儿。如果你就此以为函数式编程不过如此,恐怕是高兴地太早了。下一节对
- Stream
规约操作的介绍将刷新你现在的认识,敬请期待!
- Stream
,欢迎关注。
来源: http://www.cnblogs.com/CarpenterLee/p/6545321.html