- 只用reduce 和Lambda 表達(dá)式寫出實(shí)現(xiàn)Stream 上的map 操作的代碼害捕,如果不想返回Stream拷邢,可以返回一個List哩俭。
// reduce實(shí)現(xiàn)map
private <T, R> Stream<R> map(Stream<T> stream, Function<T, R> fun) {
return stream.reduce(new ArrayList<R>().stream(), // Stream<R>是reduce參數(shù)的的U
(u, t) -> Stream.concat(u, Stream.of(fun.apply(t))),
(a, b) -> Stream.concat(a, b));
}
// 測試方法
// Artist(String name, String nation)
@Test
public void test23() {
System.out.println(
map(Stream.of(
new Artist("a", "aaa"),
new Artist("b", "bbb"),
new Artist("c", "ccc")
), t -> t.getNation()).collect(Collectors.toList())
); // [aaa,bbb,ccc]
}
- 只用reduce 和Lambda 表達(dá)式寫出實(shí)現(xiàn)Stream 上的filter 操作的代碼震放,如果不想返回Stream筷厘,可以返回一個List。
// reduce實(shí)現(xiàn)filter
private <T> Stream<T> filter(Stream<T> stream, Predicate<T> pre) {
return stream.reduce(new ArrayList<T>().stream(), // Stream<T>是reduce的U
(u, t) -> {
if (pre.test(t))
return Stream.concat(u, Stream.of(t));
return u;
},
(a, b) -> Stream.concat(a, b)
);
}
// 測試方法
@Test
public void test24() {
System.out.println(
filter(Stream.of(
new Artist("a", "aaa"),
new Artist("b", "bb"),
new Artist("c", "c")
), t -> t.getNation().length() >= 2).collect(Collectors.toList())
);
} // [Artist("a", "aaa"), Artist("b", "bb")]
后話前普,函數(shù)式編程寫起來是挺爽肚邢,寫完了會有種看不懂的感覺... 慢慢習(xí)慣就好。關(guān)鍵是reduce
方法的使用拭卿,下面給出我的看法:
reduce
方法有3個:
//1.
Optional<T> reduce(BinaryOperator<T> accumulator);
/*
常規(guī)的累計計算器骡湖,參數(shù)泛型和返回值泛型相同,
具體的累計計算規(guī)則源代碼注釋已經(jīng)給出峻厚,
將stream第一個元素作為初始值响蕴,然后和第二個元素累計計算,
結(jié)果再次作為初始值惠桃,再和第三個元素累計計算浦夷,以此類推:
boolean foundAny = false;
T result = null;
for (T element : this stream) {
if (!foundAny) {
foundAny = true;
result = element;
}
else
result = accumulator.apply(result, element);
}
return foundAny ? Optional.of(result) : Optional.empty();
*/
//2.
T reduce(T identity, BinaryOperator<T> accumulator);
/*
具有初始值的累計計算器,和上面的reduce類似辜王,
只是初始值永遠(yuǎn)固定不變劈狐,均為 identity,
并且參數(shù) identity誓禁、accumulator 的泛型相同懈息,與返回值泛型亦相同
*/
//3.
<U> U reduce(U identity,
BiFunction<U, ? super T, U> accumulator,
BinaryOperator<U> combiner);
/*
累加器帶有3個參數(shù)肾档,前兩個參數(shù)和上面的reduce含義相同摹恰,
需要注意的是 identity 的泛型和返回值的泛型相同辫继,
而 accumulator 的函數(shù)接口變?yōu)榱?BiFunction,并且支持兩種泛型俗慈,可以和返回值泛型相同姑宽,也可不同,
上面實(shí)現(xiàn) map 方法就有兩中泛型參數(shù)闺阱,U 是 Stream<R>炮车,T 就是 Artist,
最后一個參數(shù) combiner酣溃,貌似是和并行有關(guān)瘦穆,大概是并行執(zhí)行后結(jié)果如何合并的方法,這里暫時用 concat 合并赊豌,后面再研究
*/