java8中流處理的示例分析

這篇文章主要為大家展示了“java8中流處理的示例分析”，內(nèi)容簡而易懂，條理清晰，希望能夠幫助大家解決疑惑，下面讓小編帶領(lǐng)大家一起研究并學(xué)習(xí)一下“java8中流處理的示例分析”這篇文章吧。

我就隨便舉個(gè)例子,看看Stream有多優(yōu)雅。

// 對蘋果按顏色匯總并績數(shù)量
Map<String, Long> appleCount = apples.stream()
 .collect(groupingBy(Apple::getColor, counting()));
// 過濾掉顏色為黑色的蘋果，并匯總好蘋果的總金額
Double sum = apples.stream()
 .filter(i->"black".equals(i.getColor()))
 .collect(toList);

一、lambda表達(dá)式

雖然本文重點(diǎn)是stream，但是stream中需要傳遞lambda表達(dá)式，所以簡單介紹一下lambda表達(dá)式。lambda表達(dá)式其實(shí)就是匿名函數(shù)(anonymous function),是指一類無需定義標(biāo)識(shí)符的函數(shù)或子程序。

java中匿名函數(shù)的表現(xiàn)形式，只留下入?yún)⒑头椒w中的內(nèi)容

// 普通函數(shù)
public void run(String s){
 System.out.print(s+"哈哈");
}
// 我不要名字啦！?。?
(s)->System.out.print(s+"哈哈")

誒，過去我們都用對象調(diào)方法的，你弄這個(gè)沒名的東西啥時(shí)候用啊?

java中我們通過函數(shù)式接口來使用這種匿名函數(shù)。

函數(shù)式接口

1.java中只包含一個(gè)未實(shí)現(xiàn)方法的接口。其中可以有與Object中同名的方法和默認(rèn)方法（java8中接口方法可以有默認(rèn)實(shí)現(xiàn)）。

2.java中函數(shù)式接口使用@FunctionalInterface進(jìn)行注解。Runnable、Comparator都是函數(shù)式接口。

3.java.util.function包下為我們提供很多常用的函數(shù)式接口，例如Function等。

用法舉例：

// 實(shí)現(xiàn)Runnable中的run方法，替代匿名內(nèi)部類。
Runnable r = ()->System.out.print("哈哈");
// 作為參數(shù)傳遞。
new Thread(()-> System.out.println("haha")).start();

ArrayList<Apple> list = new ArrayList<>();
list.forEach(i-> System.out.println(i.getWeight()));


// 簡化策略模式
public static List<Apple> filterApples(List<Apple> inventory,ApplePredicate p){
 List<Apple> apples = new ArrayList<>();
 for(Apple apple : inventory){
 if(p.test(apple)){
 apples.add(apple);
 }
 }
 return apples;
}
public class BigApple implement ApplePredicate{
 @Override
 public boolean test(Apple a){
 if(a.getWeight>10){
 return a
 }
 }
}
// 這是個(gè)簡單的策略模式，根據(jù)用戶的需要，創(chuàng)建不同的接口ApplePredicate實(shí)現(xiàn)類,調(diào)用時(shí)傳入不同的實(shí)現(xiàn)類就可以，但問題是如果需求過多，創(chuàng)建的實(shí)現(xiàn)類也會(huì)很多，過于臃腫不方便管理。
xx.filterApple(inventory,new BigApple);
// 使用lambda表達(dá)式，不在需要?jiǎng)?chuàng)建BigApple類
xx.filterApple(inventory,i->(i.getWeight>10));

使用lambda表達(dá)式可以簡化大量的模板代碼，并且可以向方法直接傳遞代碼。

總之

方法出參入?yún)碜院瘮?shù)式接口

//入?yún),返回void
(s)->System.out.println(s);
//入?yún)⒖眨祷豽oid
()->System.out.print("haha");
//入?yún),返回i+1
i->i+1
//后面寫代碼塊
apple->{if(apple.getWeiht>5) return "BIG";
 else return "small";
 }

好了，不多啰嗦了，如果感興趣推薦下面的文章或《Java8實(shí)戰(zhàn)》的前三章。

1.Lambda表達(dá)式有何用處？如何使用？

2.java8實(shí)戰(zhàn)

二、Stream

流是什么？

Java API的新成員，它允許你使用聲明式方式處理數(shù)據(jù)集合（類似sql，通過查詢語句表達(dá)，而不是臨時(shí)編寫一個(gè)實(shí)現(xiàn)）。

如果有人說lambda表達(dá)式不易于理解，那還勉強(qiáng)可以接受（其實(shí)過于復(fù)雜的lambda缺失不好閱讀，但通常lambda不會(huì)做太復(fù)雜的實(shí)現(xiàn)），但流真的非常的易懂易用。這個(gè)語法糖真的是甜死了。

注意事項(xiàng)：

1.流只能使用一次，遍歷結(jié)束就代表這個(gè)流被消耗掉了

2.流對集合的操作屬于內(nèi)部迭代，是流幫助我們操作，而不是外部迭代

3.流操作包含：數(shù)據(jù)源，中間操作鏈，終端操作三個(gè)部分。

基礎(chǔ)流操作

List<Double> collect = list.stream()
 // 過濾掉黑色的蘋果
 .filter(i -> "black".equals(i.getColor()))
 // 讓蘋果按照重量個(gè)價(jià)格排序
 .sorted(Comparator.comparing(Apple::getWeight)
 .thenComparing(i->i.getPrice()))
 // 篩選掉重復(fù)的數(shù)據(jù)
 .distinct()
 // 只要蘋果的價(jià)格
 .map(Apple::getPrice)
 // 只留下前兩條數(shù)據(jù)
 .limit(2)
 // 以集合的形式返回
 .collect(toList());
// 循環(huán)打印列表中元素
list.forEach(i->System.out.print(i));

Apple::getPrince<=>i -> i.getPrince()可以看做是僅涉及單一方法的語法糖,效果與lambda表達(dá)式相同，但可讀性更好。

同理

下面列表為常見操作

中間

終端

篩選與切片

List<String> strings = Arrays.asList("Hello", "World");
List<String> collect1 = strings.stream()
 // String映射成String[]
 .map(i -> i.split(""))
 // Arrays::Stream 數(shù)據(jù)數(shù)組，返回一個(gè)流String[]->Stream<String>
 // flatMap各數(shù)組并不分別映射成一個(gè)流，而是映射成流的內(nèi)容 Stream<String>->Stream
 .flatMap(Arrays::stream)
 .collect(toList());
System.out.println(collect);
----->輸出 [H, e, l, l, o, W, o, r, l, d]

歸約操作reduce

List<Integer> integers = Arrays.asList(12, 3, 45, 3, 2,-1);
// 有初始值的疊加操作
Integer reduce = integers.stream().reduce(3, (i, j) -> i + j);
Integer reduce2 = integers.stream().reduce(5, (x, y) -> x < y ? x : y);
// 無初始值的疊加操作
Optional<Integer> reduce1 = integers.stream().reduce((i, j) -> i + j);
// 無初始值的最大值
Optional<Integer> reduce4 = integers.stream().reduce(Integer::min);
// 無初始值的最大值
Optional<Integer> reduce5 = integers.stream().reduce(Integer::max);
// 求和
Optional<Integer> reduce6 = integers.stream().reduce(Integer::sum);

reduce做的事情是取兩個(gè)數(shù)進(jìn)行操作，結(jié)果返回取下一個(gè)數(shù)操作，以次類推。

Optional是java8引入的新類，避免造成空指針異常，在集合為空時(shí)，結(jié)果會(huì)包在Optional中，可以用isPresent()方法來判斷是否為空值。

無初始值的情況下可能為空，故返回Optional

中間

終端

數(shù)值流

包裝類型的各種操作都會(huì)有拆箱操作和裝箱操作，嚴(yán)重影響性能。所以Java8為我們提供了原始數(shù)值流。

// 數(shù)值流求平均值
OptionalDouble average = apples.stream()
 .mapToDouble(Apple::getPrice)
 .average();
// 數(shù)值流求和
OptionalDouble average = apples.stream()
 .mapToDouble(Apple::getPrice)
 .sum();
// 數(shù)值流求最大值，沒有則返回2
double v = apples.stream()
 .mapToDouble(Apple::getPrice)
 .max().orElse(2);
// 生成隨機(jī)數(shù)
IntStream s = IntStream.rangeClosed(1,100);

下面列表為常見數(shù)值流操作操作

中間

終端，終端操作與List一般流類似

構(gòu)建流

值創(chuàng)建

Stream<String> s = Stream.of("java","python");

數(shù)組創(chuàng)建

int[] i = {2,3,4,5};
Stream<int> = Arrays.stream(i);

由文件生成,NIO API已經(jīng)更新，以便利用Stream API

Stream<String> s = Files.lines(Paths.get("data.txt"),Charset.defaultCharset());

由函數(shù)創(chuàng)建流：無限流

// 迭代
Stream.iterate(0,n->n+2)
 .limit(10)
 .forEach(System.out::println);
// 生成,需要傳遞實(shí)現(xiàn)Supplier<T>類型的Lambda提供的新值
Stream.generate(Math.random)
 .limit(5)
 .forEach(System.out::println);

以上是“java8中流處理的示例分析”這篇文章的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對大家有所幫助，如果還想學(xué)習(xí)更多知識(shí)，歡迎關(guān)注億速云行業(yè)資訊頻道！