淺談JAVA8給我?guī)Я耸裁础鞯母拍詈褪占?/h1>

 更新時(shí)間：2019年04月01日 09:37:41   作者：落葉隨風(fēng)  

這篇文章主要介紹了JAVA8流的概念和收集器，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

到現(xiàn)在為止，筆者不敢給流下定義，從概念來講他應(yīng)該也是一種數(shù)據(jù)元素才是?？墒窃谖覀兦懊娴拇a例子中我們可以看到他更多的好像在表示他是一組處理數(shù)據(jù)的行為組合。這讓筆者很難去理解他的定義。所以筆者不表態(tài)。各位同志自行理解吧。

在沒有流以前，處理集合里面的數(shù)據(jù)一般都會(huì)用到顯示的迭代器。用一下前面學(xué)生的例子吧。目標(biāo)是獲得學(xué)分大于5的前倆位同學(xué)。

package com.aomi;

import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import static java.util.stream.Collectors.toList;

public class Main {

 public static void main(String[] args) {
  // TODO Auto-generated method stub

  List<Student> stus = getSources();

  Iterator<Student> ite = stus.iterator();

  List<String> names = new ArrayList<>();
  int limit = 2;
  while (ite.hasNext() && limit > 0) {

   Student stu = ite.next();

   if (stu.getScore() > 5) {

    names.add(stu.getName());
    limit--;
   }
  }

  for (String name : names) {
   System.out.println(name);
  }

 }

 public static List<Student> getSources() {
  List<Student> students = new ArrayList<>();

  Student stu1 = new Student();

  stu1.setName("lucy");
  stu1.setSex(0);
  stu1.setPhone("13700227892");
  stu1.setScore(9);

  Student stu2 = new Student();
  stu2.setName("lin");
  stu2.setSex(1);
  stu2.setPhone("15700227122");
  stu2.setScore(9);

  Student stu3 = new Student();
  stu3.setName("lili");
  stu3.setSex(0);
  stu3.setPhone("18500227892");
  stu3.setScore(8);

  Student stu4 = new Student();

  stu4.setName("dark");
  stu4.setSex(1);
  stu4.setPhone("16700555892");
  stu4.setScore(6);

  students.add(stu1);
  students.add(stu2);
  students.add(stu3);
  students.add(stu4);

  return students;
 }

}

如果用流的話是這樣子的。

public static void main(String[] args) {
  // TODO Auto-generated method stub

  List<Student> stus = getSources();

  List<String> names = stus.stream()
    .filter(st -> st.getScore() > 5)
    .limit(2)
    .map(st -> st.getName())
    .collect(toList());
  for (String name : names) {
   System.out.println(name);
  }

 }

把這倆段代碼相比較主要是為了說明一個(gè)概念：以前做法都是在外部迭代，最為體現(xiàn)就是筆者在外面定義了一個(gè)集合names 。而流卻什么也沒有，現(xiàn)在我們應(yīng)該能清楚感受到流是在內(nèi)部迭代。也就是說流已經(jīng)幫你做好了迭代。我們只要傳入相關(guān)的函數(shù)就可以得到想要的結(jié)果。至于內(nèi)部迭代的好處，筆者沒有辦法親身的感受，唯一的感覺就是代碼變的簡單明了了。但是官方說Stream庫為了我們?cè)趦?nèi)部迭代里面做了很多優(yōu)化和充公利用性能的操作。比如并行操作。所以筆者就聽官方了。

事實(shí)上，在用流的過程中，我們用到很多方法函數(shù)。比如上面的limit方法，filter方法等。這個(gè)定義為流操作。但是不管是什么操作，你必須要有一個(gè)數(shù)據(jù)源吧?？偨Y(jié)如下：

1. 數(shù)據(jù)源：用于生成流的數(shù)據(jù)，比如集合。
2. 流操作：類似于limit方法，filter方法。

流還有一種特點(diǎn)——部分流操作是沒有執(zhí)行的。一般都是在collect函數(shù)執(zhí)行的時(shí)候，才開始執(zhí)行個(gè)個(gè)函數(shù)。所以我們可以細(xì)分一下流操作：

1. 數(shù)據(jù)源：用于生成流的數(shù)據(jù)，比如集合。
2. 中間操作：類似于limit方法，filter方法。這些操作做變了一個(gè)操作鏈，有一點(diǎn)流水線的概念。
3. 終端操作：執(zhí)行上面的操作鏈。比如collect函數(shù)。

從上面的講解我們就可以感覺流好像是先收集相關(guān)的目標(biāo)操作，什么意思呢？就是先把要做的事情計(jì)劃一下，最后一聲令下執(zhí)行。而下這個(gè)命令是collect函數(shù)。這一點(diǎn)跟.NET的Linq是很像的。同時(shí)記得他只能執(zhí)行一次。也就是說這個(gè)流執(zhí)行一次之后，就不可能在用了。
筆者列一下以前的用到的函數(shù)

forEach：終端
collect：終端
count：終端
limit：中間
filter：中間
map：中間
sorted：中間

到目前為止我們用到的流都是通過集合來建一個(gè)流。筆者對(duì)此從來沒有講過。現(xiàn)在筆者來講些構(gòu)建流的方式。
在stream庫里面為我們提供了這樣子一個(gè)方法——Stream.of

package com.aomi;

import java.util.Optional;
import java.util.stream.Stream;

public class Main {

	public static void main(String[] args) {
		// TODO Auto-generated method stub

		Stream stream = Stream.of("I", "am", "aomi");

		Optional<String> firstWord = stream.findFirst();
		
		if(firstWord.isPresent())
		{
			System.out.println("第一個(gè)字："+firstWord.get());
		}
	}

}

運(yùn)行結(jié)果：

去看一下of方法的代碼。如下

public static<T> Stream<T> of(T... values) {
  return Arrays.stream(values);
 }

說明我們可能指定一個(gè)類型來建一個(gè)流。上面可以修改為

Stream<String> stream = Stream.of("I", "am", "aomi");

findFirst函數(shù)用于表示返回第一個(gè)值。那就是可能數(shù)據(jù)源是一個(gè)空呢？所以他有可以會(huì)返回null。所以就是用一個(gè)叫Optional類的表示可以為空。這樣子我們就可以用Optional類的方法進(jìn)一步做安全性的操作。比如判斷有沒有值（isPresent()）
筆者想要建一個(gè)int類型的數(shù)組流玩玩。為了方便筆者便試給一下上面的代碼。卻發(fā)現(xiàn)報(bào)錯(cuò)了。

如果我把int改為Integer呢？沒有問題了。所以注意要用引用類型的。int類型對(duì)應(yīng)為Integer類型。

package com.aomi;

import java.util.Optional;
import java.util.stream.Stream;

public class Main {

 public static void main(String[] args) {
  // TODO Auto-generated method stub

  Stream<Integer> stream = Stream.of(1, 2, 9);

  Optional<Integer> firstWord = stream.findFirst();
  
  if(firstWord.isPresent())
  {
   System.out.println("第一個(gè)字："+firstWord.get());
  }
 
 }

}

運(yùn)行結(jié)果：

那想要用int類型呢?什么辦呢？改改

package com.aomi;

import java.util.OptionalInt;
import java.util.stream.IntStream;

public class Main {

 public static void main(String[] args) {
  // TODO Auto-generated method stub

  IntStream stream = IntStream.of(1, 2, 9);

  OptionalInt firstWord = stream.findFirst();
  
  if(firstWord.isPresent())
  {
   System.out.println("第一個(gè)字："+firstWord.getAsInt());
  }
 
 }

}

運(yùn)行結(jié)果：

我們以上面的例子來一個(gè)猜測：是不是Double類型，只要修改為DoubleStream就行呢？試試。

package com.aomi;

import java.util.OptionalDouble;
import java.util.stream.DoubleStream;

public class Main {

 public static void main(String[] args) {
  // TODO Auto-generated method stub

  DoubleStream stream = DoubleStream.of(1.3, 2.3, 9.5);

  OptionalDouble firstWord = stream.findFirst();
  
  if(firstWord.isPresent())
  {
   System.out.println("第一個(gè)字："+firstWord.getAsDouble());
  }
 
 }

}

運(yùn)行結(jié)果：

結(jié)果很明顯，我們的猜測是對(duì)的。所以見意如果你操作的流是一個(gè)int或是double的話，請(qǐng)進(jìn)可能的用XxxStream 來建流。這樣子在流的過程中不用進(jìn)行拆裝和封裝了。必竟這是要性能的。在看一下如果數(shù)據(jù)源是一個(gè)數(shù)組的情況我們?nèi)绾紊闪髂兀?/p>

public static Collector<CharSequence, ?, String> joining(CharSequence delimiter,
                CharSequence prefix,
                CharSequence suffix) {
  return new CollectorImpl<>(
    () -> new StringJoiner(delimiter, prefix, suffix),
    StringJoiner::add, StringJoiner::merge,
    StringJoiner::toString, CH_NOID);
 }

在看一個(gè)叫toList函數(shù)的代碼。

public static <T>
 Collector<T, ?, List<T>> toList() {
   return new CollectorImpl<>((Supplier<List<T>>) ArrayList::new, List::add,
         (left, right) -> { left.addAll(right); return left; },
         CH_ID);
 }

我們發(fā)現(xiàn)他會(huì)共同的返回一個(gè)Collector類型。從上面我們就可以知道他的任務(wù)就是用去處理最后數(shù)據(jù)。我們把他定為收集器。讓我們看一下收集器的接口代碼吧;

public interface Collector<T, A, R> {

 Supplier<A> supplier();

 BiConsumer<A, T> accumulator();

 BinaryOperator<A> combiner();

 Function<A, R> finisher();

 Set<Characteristics> characteristics();
}

光看前面四個(gè)方法是不是有一點(diǎn)熟悉的感覺。想要說明這個(gè)五個(gè)方法的作用。就必須明白一個(gè)概念——并行歸約。前面筆者講過流是一個(gè)內(nèi)部迭代，也說Stream庫為我們做一個(gè)很多優(yōu)化的事情。其中一個(gè)就是并行。他用到了JAVA 7引入的功能——分支/合并框架。也就是說流會(huì)以遞歸的方式拆分成很多子流，然后子流可以并行執(zhí)行。最后在倆倆的子流的結(jié)果合并成一個(gè)最終結(jié)果。而這倆倆合并的行為就叫歸約 。如圖下。引用于《JAVA8實(shí)戰(zhàn)》

我們必須根據(jù)圖上的意思來走。子流的圖里面會(huì)調(diào)用到Collector類的三個(gè)方法。

1. supplier方法：用創(chuàng)建數(shù)據(jù)存儲(chǔ)的地方。
2. accumulator方法：用于子流執(zhí)行過程的迭代工作。即是遍歷每一項(xiàng)都會(huì)執(zhí)行。所以可以這里做一些工作。
3. finisher方法：返回最后的結(jié)果，你可以在這里進(jìn)一步處理結(jié)果。

每一個(gè)子流結(jié)束這之后，就是倆倆合并。這個(gè)時(shí)候就要看流的機(jī)制圖了。

1. combiner方法：會(huì)傳入每一個(gè)子流的結(jié)果過來，我們就可以在這里在做一些工作。
2. finisher方法：返回最后的結(jié)果。同上面子流的一樣子。

好像沒有characteristics什么事情。不是這樣子的。這個(gè)方法是用來說明當(dāng)前這個(gè)流具備哪些優(yōu)化。這樣子執(zhí)行流的時(shí)候，就可以很清楚的知道要以什么樣子的方式執(zhí)行了。比如并行。
他是一個(gè)enum類。值如下

1. UNORDERED：這個(gè)表示執(zhí)行過程中結(jié)果不受歸約和遍歷的影響
2. CONCURRENT：表示可以多個(gè)線和調(diào)用accumulator方法。并且可以執(zhí)行并行。當(dāng)然前無序數(shù)據(jù)的才并行。除非收集器標(biāo)了UNORDERED。
3. IDENTITY_FINISH：表示這是一個(gè)恒等函數(shù)，就是做了結(jié)果也一樣子。不用做了可以跳過了。

由了上面的講說明，我們?cè)趤韺懸粋€(gè)自己的收集器吧——去除相同的單詞
DistinctWordCollector類：

package com.aomi;

import java.util.ArrayList;
import java.util.Collections;
import java.util.EnumSet;
import java.util.List;
import java.util.Set;
import java.util.function.BiConsumer;
import java.util.function.BinaryOperator;
import java.util.function.Function;
import java.util.function.Supplier;
import java.util.stream.Collector;

public class DistinctWordCollector implements Collector<String, List<String>, List<String>> {

 @Override
 public Supplier<List<String>> supplier() {
  // TODO Auto-generated method stub
  return () -> new ArrayList<String>();
 }

 /**
  * 子流的處理項(xiàng)的過程
  */
 @Override
 public BiConsumer<List<String>, String> accumulator() {
  // TODO Auto-generated method stub
  return (List<String> src, String val) -> {

   if (!src.contains(val)) {
    src.add(val);
   }
  };
 }

 /**
  * 倆倆并合的執(zhí)行函數(shù)
  */
 @Override
 public BinaryOperator<List<String>> combiner() {
  // TODO Auto-generated method stub
  return (List<String> src1, List<String> src2) -> {
   for (String val : src2) {
    if (!src1.contains(val)) {
     src1.add(val);
    }
   }
   return src1;
  };
 }

 @Override
 public Function<List<String>, List<String>> finisher() {
  // TODO Auto-generated method stub
  return Function.identity();
 }

 @Override
 public Set<Characteristics> characteristics() {
  // TODO Auto-generated method stub
  return Collections.unmodifiableSet(EnumSet.of(Characteristics.IDENTITY_FINISH, Characteristics.CONCURRENT));
 }

}

 Main:

public static void main(String[] args) {
  // TODO Auto-generated method stub

  List<String> words = Arrays.asList("aomi","lili","lucy","aomi","Nono");

  List<String> vals = words.stream().collect(new DistinctWordCollector());
  
  for (String val : vals) {
   System.out.println(val);
  }
 }

運(yùn)行結(jié)果

結(jié)果確定就是我們想要的——去掉了重復(fù)的aomi

以上所述是小編給大家介紹的JAVA8流的概念和收集器詳解整合，希望對(duì)大家有所幫助，如果大家有任何疑問請(qǐng)給我留言，小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)腳本之家網(wǎng)站的支持！

您可能感興趣的文章:

• Java SpringCache+Redis緩存數(shù)據(jù)詳解
• 使用jvisualvm配合Visual GC插件監(jiān)控Java程序詳細(xì)總結(jié)
• 解析Java內(nèi)存分配和回收策略以及MinorGC、MajorGC、FullGC
• Java SpringBoot整合SpringCloud
• 深入理解Java SpringCloud Ribbon 負(fù)載均衡
• java垃圾收集器與內(nèi)存分配策略詳解
• Java8 Stream Collectors收集器使用方法解析
• java 8如何自定義收集器（collector）詳解
• JAVA垃圾收集器與內(nèi)存分配策略詳解
• java中的GC收集器詳情

• JAVA8
• 流
• 概念
• 收集器

相關(guān)文章

• 

  JAVA?流程控制專項(xiàng)精講

  不喜歡羅里吧嗦，講的很精簡易懂。從基礎(chǔ)開始講，后續(xù)會(huì)講到JAVA高級(jí)，中間會(huì)穿插面試題和項(xiàng)目實(shí)戰(zhàn)，希望能給大家?guī)韼椭?/div> 2022-03-03
• 

  解決Spring Security的權(quán)限配置不生效問題

  這篇文章主要介紹了解決Spring Security的權(quán)限配置不生效問題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

  2022-03-03
• 

  Java8 自定義CompletableFuture的原理解析

  這篇文章主要介紹了Java8 自定義CompletableFuture的原理解析，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

  2021-11-11
• 

  mybatis插入數(shù)據(jù)后返回自增主鍵ID的兩種實(shí)現(xiàn)方式

  這篇文章主要介紹了mybatis插入數(shù)據(jù)后返回自增主鍵ID的兩種實(shí)現(xiàn)方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教

  2024-05-05
• 

  SpringBoot實(shí)現(xiàn)初始化的三種策略模式

  本文主要介紹了SpringBoot實(shí)現(xiàn)初始化的三種策略模式,包括默認(rèn)初始化策略、懶加載初始化策略和自定義初始化策略,具有一定的參考價(jià)值,感興趣的可以了解一下

  2024-12-12
• 

  windows10 JDK安裝及配置環(huán)境變量與Eclipse安裝教程

  這篇文章主要介紹了windows10 JDK安裝及配置環(huán)境變量與Eclipse安裝,本文圖文并茂給大家介紹的非常詳細(xì)，具有一定的參考借鑒價(jià)值，需要的朋友可以參考下

  2019-10-10
• 

  如何利用Spring的@Import擴(kuò)展點(diǎn)與spring進(jìn)行無縫整合

  這篇文章主要介紹了如何利用Spring的@Import擴(kuò)展點(diǎn)與spring進(jìn)行無縫整合的實(shí)例代碼，本文給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下

  2020-08-08
• 

  Java多線程之Callable接口的實(shí)現(xiàn)

  這篇文章主要介紹了Java多線程之Callable接口的實(shí)現(xiàn)，Callable和Runnbale一樣代表著任務(wù)，區(qū)別在于Callable有返回值并且可以拋出異常。感興趣的小伙伴們可以參考一下

  2018-08-08
• 

  Spring Boot整合MyBatis連接Oracle數(shù)據(jù)庫的步驟全紀(jì)錄

  這篇文章主要給大家介紹了關(guān)于Spring Boot整合MyBatis連接Oracle數(shù)據(jù)庫的相關(guān)資料，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

  2018-07-07
• 

  Java實(shí)現(xiàn)用Freemarker完美導(dǎo)出word文檔（帶圖片）

  這篇文章主要介紹了Java實(shí)現(xiàn)用Freemarker完美導(dǎo)出word文檔（帶圖片），具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

  2017-07-07

最新評(píng)論