欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

java8中forkjoin和optional框架使用

 更新時(shí)間:2017年12月24日 16:04:41   作者:appointint  
這篇文章主要介紹了java8中forkjoin和optional框架使用心得以及用法講解,需要的朋友參考下吧。

并行流與串行流

并行流就是把一個(gè)內(nèi)容分成多個(gè)數(shù)據(jù)塊,并用不同的線程分別處理每個(gè)數(shù)據(jù)塊的流。

java 8 中將并行進(jìn)行了優(yōu)化,我們可以很容易的對(duì)數(shù)據(jù)進(jìn)行并行操作。Stream API 可以聲明性地通過(guò) parallel()與 sequential()在并行流與順序流之間進(jìn)行切換。

了解 Fork/Join 框架

Fork/Join 框架:就是在必要的情況下,將一個(gè)大任務(wù),進(jìn)形拆分(fork)成若干個(gè)小任務(wù)(拆到不可再拆時(shí)),再將一個(gè)個(gè)的小任務(wù)運(yùn)行的結(jié)果進(jìn)行join匯總。

Fork/Join 框架與傳統(tǒng)線程池的區(qū)別:

采用“工作竊取”模式(work-stealing):

當(dāng)執(zhí)行新的任務(wù)時(shí),它可以將其拆分成更小的任務(wù)執(zhí)行,并將小任務(wù)加到線程隊(duì)列中,然后再?gòu)囊粋€(gè)隨機(jī)線程的隊(duì)列中偷一個(gè)并把它放在自己的隊(duì)列中。

相對(duì)于一般的線程池實(shí)現(xiàn),fork/join框架的優(yōu)勢(shì)體現(xiàn)在對(duì)其中包含的任務(wù)的處理方式上.在一般的線程池中,如果一個(gè)線程正在執(zhí)行的任務(wù)由于某些原因無(wú)法繼續(xù)運(yùn)行,那么該線程會(huì)處于等待狀態(tài).而在fork/join框架實(shí)現(xiàn)中,如果某個(gè)子問(wèn)題由于等待另外一個(gè)子問(wèn)題的完成而無(wú)法繼續(xù)運(yùn)行.那么處理該子問(wèn)題的線程會(huì)主動(dòng)尋找其他尚未運(yùn)行的子問(wèn)題來(lái)執(zhí)行.這種方式減少了線程的等待時(shí)間,提高了性能。

import java.time.Duration;
import java.time.Instant;
import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.ForkJoinTask;
import java.util.concurrent.RecursiveTask;
import java.util.stream.LongStream;
public class TestForkJoin {
  public static void main(String[] xx){
    
  }
  private static void test1(){
  	Instant start=Instant.now();
    ForkJoinPool pool=new ForkJoinPool();
    ForkJoinTask<Long> task = new ForkJoinCalculate(0L, 10000000000L);
    long sum = pool.invoke(task);
    System.out.println(sum);

    Instant end=Instant.now();
    System.out.println("消耗時(shí)間"+Duration.between(start, end).toMillis()+"ms");//消耗時(shí)間3409ms
  }
  private static void test2(){
    Instant start=Instant.now();

    Long sum = LongStream.rangeClosed(0L, 10000L)
               .parallel()
               .reduce(0,Long::sum);
    System.out.println(sum);

    Instant end=Instant.now();
    System.out.println("消耗時(shí)間" + Duration.between(start, end).toMillis()+"ms");//消耗時(shí)間2418ms
  } 
}
class ForkJoinCalculate extends RecursiveTask<Long>{

  private static final long serialVersionUID = 1234567890L;//序列號(hào)

  private long start;
  private long end;
  private static final long THRESHOLD=2500000000L;//臨界值

  public ForkJoinCalculate(long start,long end) {
    this.start=start;
    this.end=end;
  }
  @Override
  protected Long compute() {
    long length = end - start;
    if(length <= THRESHOLD){
      long sum=0;
      for(long i = start; i <= end; i++){
        sum += i;
      }
      return sum;
    }else{
      long middle = (start+end)/2;
      ForkJoinCalculate left = new ForkJoinCalculate(start, middle);
      left.fork();

      ForkJoinCalculate right=new ForkJoinCalculate(middle+1, end);
      right.fork();

      return left.join() + right.join();
    }
  }

}

Optional類

Optional< T>類(java.util.Optional) 是一個(gè)容器類,代表一個(gè)值存在或不存在。

原來(lái)用null表示一個(gè)值不存在,現(xiàn)在 Optional可以更好的表達(dá)這個(gè)概念。并且可以避免空指針異常。

常用方法:

Optional.of(T t) : 創(chuàng)建一個(gè) Optional 實(shí)例

Optional.empty() : 創(chuàng)建一個(gè)空的 Optional 實(shí)例

Optional.ofNullable(T t):若 t 不為 null,創(chuàng)建 Optional 實(shí)例,否則創(chuàng)建空實(shí)例

isPresent() : 判斷是否包含值

orElse(T t) : 如果調(diào)用對(duì)象包含值,返回該值,否則返回t

orElseGet(Supplier s) :如果調(diào)用對(duì)象包含值,返回該值,否則返回 s 獲取的值

map(Function f): 如果有值對(duì)其處理,并返回處理后的Optional,否則返回 Optional.empty()

flatMap(Function mapper):與 map 類似,要求返回值必須是Optional

public class OptionalTest1 {
  public static void main(String[] args){
  	
  	String s = new String("Ha");
//  	Optional<String> op = Optional.of(null);
//  	
//  	String s1 = op.get();
//  	System.out.println(s1);
  	
//  	Optional<String> op1 = Optional.empty();
//  	String s1 = op1.get();
//  	System.out.println(s1);  
  	
  	Optional<String> op1 = Optional.ofNullable(null);
//  	System.out.println(op1.isPresent());
//  	System.out.println(op1.orElse(new String("Google")));
  	//System.out.println(op1.orElseGet(() -> new String("Ali")));
  	
  	Optional<String> op2 = op1.map((x) -> x.toLowerCase());
  	String s2 = op2.get();
  	System.out.println(s2);  	
  }
}
@Test
  public void test5(){
    Man man=new Man();
    String name=getGodnessName(man);
    System.out.println(name);
  }
  //需求:獲取一個(gè)男人心中女神的名字
  public String getGodnessName(Man man){
    if(man!=null){
      Godness g=man.getGod();
      if(g!=null){
        return g.getName();
      }
    }
    return "蒼老師";
  }
  //運(yùn)用Optional的實(shí)體類
  @Test
  public void test6(){
    Optional<Godness> godness=Optional.ofNullable(new Godness("林志玲"));
    Optional<NewMan> op=Optional.ofNullable(new NewMan(godness));
    String name=getGodnessName2(op);
    System.out.println(name);
  }
  public String getGodnessName2(Optional<NewMan> man){
    return man.orElse(new NewMan())
         .getGodness()
         .orElse(new Godness("蒼老師"))
         .getName();
  }
//注意:Optional 不能被序列化
public class NewMan {
  private Optional<Godness> godness = Optional.empty();
  private Godness god;
  public Optional<Godness> getGod(){
    return Optional.of(god);
  }
  public NewMan() {
  }
  public NewMan(Optional<Godness> godness) {
    this.godness = godness;
  }
  public Optional<Godness> getGodness() {
    return godness;
  }
  public void setGodness(Optional<Godness> godness) {
    this.godness = godness;
  }
  @Override
  public String toString() {
    return "NewMan [godness=" + godness + "]";
  }
}

以上就是我們給大家整理的java8中forkjoin和optional框架使用心得的全部?jī)?nèi)容,大家在學(xué)習(xí)的時(shí)候如果還有任何不明白的地方可以在下方的留言區(qū)討論。

相關(guān)文章

  • SpringBoot開(kāi)發(fā)詳解之Controller接收參數(shù)及參數(shù)校驗(yàn)

    SpringBoot開(kāi)發(fā)詳解之Controller接收參數(shù)及參數(shù)校驗(yàn)

    數(shù)據(jù)校驗(yàn)是為了使系統(tǒng)更完整,數(shù)據(jù)更精確,同時(shí)也有利于維護(hù)數(shù)據(jù)的安全性,下面這篇文章主要給大家介紹了關(guān)于SpringBoot開(kāi)發(fā)詳解之Controller接收參數(shù)及參數(shù)校驗(yàn)的相關(guān)資料,需要的朋友可以參考下
    2022-03-03
  • Spring MVC請(qǐng)求參數(shù)的深入解析

    Spring MVC請(qǐng)求參數(shù)的深入解析

    這篇文章主要給大家介紹了關(guān)于Spring MVC請(qǐng)求參數(shù)解析的相關(guān)資料,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2021-05-05
  • JDBC中PreparedStatement詳解以及應(yīng)用場(chǎng)景實(shí)例介紹

    JDBC中PreparedStatement詳解以及應(yīng)用場(chǎng)景實(shí)例介紹

    PreparedStatement對(duì)象代表的是一個(gè)預(yù)編譯的SQL語(yǔ)句,用它提供的setter方法可以傳入查詢的變量,這篇文章主要給大家介紹了關(guān)于JDBC中PreparedStatement詳解以及應(yīng)用場(chǎng)景實(shí)例介紹的相關(guān)資料,需要的朋友可以參考下
    2024-02-02
  • Java反射獲取class對(duì)象方式解析

    Java反射獲取class對(duì)象方式解析

    這篇文章主要介紹了Java反射獲取class對(duì)象方式解析,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
    2019-11-11
  • Kotlin開(kāi)發(fā)Android應(yīng)用實(shí)例詳解

    Kotlin開(kāi)發(fā)Android應(yīng)用實(shí)例詳解

    這篇文章主要介紹了Kotlin開(kāi)發(fā)Android應(yīng)用實(shí)例詳解的相關(guān)資料,需要的朋友可以參考下
    2017-05-05
  • 詳解RestTemplate?用法

    詳解RestTemplate?用法

    RestTemplate?是從?Spring3.0?開(kāi)始支持的一個(gè)?HTTP?請(qǐng)求工具,也有的稱之為網(wǎng)絡(luò)框架,說(shuō)白了就是Java版本的一個(gè)postman,這篇文章主要介紹了詳解RestTemplate?用法,需要的朋友可以參考下
    2022-07-07
  • 淺析java快速排序算法

    淺析java快速排序算法

    這篇文章主要介紹了淺析java快速排序算法,需要的朋友可以參考下
    2015-02-02
  • Java深入講解instanceof關(guān)鍵字的使用

    Java深入講解instanceof關(guān)鍵字的使用

    instanceof 是 Java 的一個(gè)二元操作符,類似于 ==,>,< 等操作符。instanceof 是 Java 的保留關(guān)鍵字。它的作用是測(cè)試它左邊的對(duì)象是否是它右邊的類的實(shí)例,返回 boolean 的數(shù)據(jù)類型
    2022-05-05
  • Python基礎(chǔ)之如何使用multiprocessing模塊

    Python基礎(chǔ)之如何使用multiprocessing模塊

    今天帶大家學(xué)習(xí)python多進(jìn)程的相關(guān)知識(shí),文中對(duì)multiprocessing模塊的使用作了非常詳細(xì)的介紹,需要的朋友可以參考下
    2021-06-06
  • 解決java idea新建子目錄時(shí)命名不是樹(shù)形結(jié)構(gòu)的問(wèn)題

    解決java idea新建子目錄時(shí)命名不是樹(shù)形結(jié)構(gòu)的問(wèn)題

    這篇文章主要介紹了解決java idea新建子目錄時(shí)命名不是樹(shù)形結(jié)構(gòu)的問(wèn)題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧
    2020-08-08

最新評(píng)論