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

Java協(xié)程編程之Loom項(xiàng)目實(shí)戰(zhàn)記錄

 更新時(shí)間:2021年08月20日 08:42:11   作者:公眾號(hào)程序員學(xué)長(zhǎng)  
這篇文章主要介紹了Java協(xié)程編程之Loom項(xiàng)目嘗鮮,如果用嘗鮮的角度去使用Loom項(xiàng)目,可以提前窺探JVM開發(fā)者們是如何基于協(xié)程這個(gè)重大特性進(jìn)行開發(fā)的,這對(duì)于提高學(xué)習(xí)JDK內(nèi)核代碼的興趣有不少幫助,需要的朋友可以參考下

前提

之前很長(zhǎng)一段時(shí)間關(guān)注JDK協(xié)程庫(kù)的開發(fā)進(jìn)度,但是前一段時(shí)間比較忙很少去查看OpenJDK官網(wǎng)的內(nèi)容。Java協(xié)程項(xiàng)目Loom(因?yàn)轫?xiàng)目還在開發(fā)階段,OpenJDK給出的官網(wǎng)https://openjdk.java.net/projects/loom中只有少量Loom項(xiàng)目相關(guān)的信息)已經(jīng)在2018年之前立項(xiàng),目前已經(jīng)發(fā)布過基于JDK17編譯和JDK18編譯等早期版本,筆者在下載Loom早期版本的時(shí)候只找到JDK18編譯的版本:

下載入口在:https://jdk.java.net/loom

由于該JDK版本過高,目前可以使用主流IDE導(dǎo)入Loom-JDK-18+9進(jìn)行代碼高亮和語(yǔ)法提醒,暫時(shí)找不到方法進(jìn)行編譯,暫時(shí)使用該JDK執(zhí)行目錄下的的javac命令腳本進(jìn)行編譯,使用java命令腳本運(yùn)行。

Loom項(xiàng)目簡(jiǎn)單介紹

Loom - Fibers, Continuations and Tail-Calls for the JVM

Loom項(xiàng)目的標(biāo)題已經(jīng)凸顯了引入的三大新特性:

  • Fibers:幾年前看過當(dāng)時(shí)的Loom項(xiàng)目的測(cè)試代碼就是使用Fiber這個(gè)API(現(xiàn)在這個(gè)API已經(jīng)被移除),意為輕量級(jí)線程,即協(xié)程,又稱為輕量級(jí)用戶線程,很神奇的是在目前的JDK中實(shí)際上稱為Virtual Thread(虛擬線程)
  • Continuations:直譯為"連續(xù)",實(shí)現(xiàn)上有點(diǎn)像閉包,參考不少資料,尚未準(zhǔn)確理解其具體含義,感覺可以"粗暴"解讀為"程序接下來要執(zhí)行什么"或者"下一個(gè)要執(zhí)行的代碼塊"
  • Tail-Calls:尾調(diào)用VM級(jí)別支持

三個(gè)新特性不詳細(xì)展開,目前只是EA版本,還存在修改的可能性,所以也沒必要詳細(xì)展開。

Virtual Thread使用

當(dāng)前版本Loom項(xiàng)目中協(xié)程使用并沒有引入一個(gè)新的公開的虛擬線程VirtualThread類,雖然真的存在VirtualThread,但這個(gè)類使用default修飾符,隱藏在java.lang包中,并且VirtualThreadThread的子類。協(xié)程的創(chuàng)建API位于Thread類中:

使用此API創(chuàng)建協(xié)程如下:

public static void main(String[] args) {
    Thread fiber = Thread.startVirtualThread(() -> System.out.println("Hello Fiber"));
}

從當(dāng)前的源碼可知:

  • VirtualThread會(huì)通過Thread.currentThread()獲取父線程的調(diào)度器,如果在main方法運(yùn)行,那么上面代碼中的協(xié)程實(shí)例的父線程就是main線程
  • 默認(rèn)的調(diào)度器為系統(tǒng)創(chuàng)建的ForkJoinPool實(shí)例(VirtualThread.DEFAULT_SCHEDULER),輸入的Runnable實(shí)例會(huì)被封裝為RunContinuation,最終由調(diào)度器執(zhí)行
  • 對(duì)于timed unpark(正在阻塞,等待喚醒)的協(xié)程,使用系統(tǒng)創(chuàng)建的ScheduledExecutorService實(shí)例進(jìn)行喚醒
  • 這個(gè)靜態(tài)工廠方法創(chuàng)建完協(xié)程馬上運(yùn)行,返回的是協(xié)程實(shí)例

如果按照上面的Thread.startVirtualThread()方法去創(chuàng)建協(xié)程,顯然無法定義協(xié)程的名稱等屬性。Loom項(xiàng)目為Thread類引入了建造者模式,比較合理地解決了這個(gè)問題:

// 創(chuàng)建平臺(tái)線程建造器,對(duì)應(yīng)于Thread實(shí)例
public static Builder.OfPlatform ofPlatform() {
    return new ThreadBuilders.PlatformThreadBuilder();
}

// 創(chuàng)建虛擬線程建造器,對(duì)應(yīng)于VirtualThread
public static Builder.OfVirtual ofVirtual() {
    return new ThreadBuilders.VirtualThreadBuilder();
}

簡(jiǎn)單說就是:

  • ofPlatform()方法用于構(gòu)建Thread實(shí)例,這里的Platform Thread(平臺(tái)線程)其實(shí)就是JDK1.0引入的線程實(shí)例,普通的用戶線程
  • ofVirtual()方法用于構(gòu)建VirtualThread實(shí)例,也就是構(gòu)建協(xié)程實(shí)例

這兩個(gè)建造器實(shí)例的所有Setter方法鏈展開如下:

public static void main(String[] args) {
    Thread.Builder.OfPlatform platformThreadBuilder = Thread.ofPlatform()
            // 是否守護(hù)線程
            .daemon(true)
            // 線程組
            .group(Thread.currentThread().getThreadGroup())
            // 線程名稱
            .name("thread-1")
            // 線程名稱前綴 + 起始自增數(shù)字 => prefix + start,下一個(gè)創(chuàng)建的線程名稱就是prefix + (start + 1)
            // start > 0的情況下會(huì)覆蓋name屬性配置
            .name("thread-", 1L)
            // 是否啟用ThreadLocal
            .allowSetThreadLocals(false)
            // 是否啟用InheritableThreadLocal
            .inheritInheritableThreadLocals(false)
            // 設(shè)置優(yōu)先級(jí)
            .priority(100)
            // 設(shè)置線程棧深度
            .stackSize(10)
            // 設(shè)置未捕獲異常處理器
            .uncaughtExceptionHandler(new Thread.UncaughtExceptionHandler() {
                @Override
                public void uncaughtException(Thread t, Throwable e) {

                }
            });
    // thread-1
    Thread firstThread = platformThreadBuilder.unstarted(() -> System.out.println("Hello Platform Thread First"));
    // thread-2
    Thread secondThread = platformThreadBuilder.unstarted(() -> System.out.println("Hello Platform Thread Second"));
    Thread.Builder.OfVirtual virtualThreadBuilder = Thread.ofVirtual()
            // 協(xié)程名稱
            .name("fiber-1")
            // 協(xié)程名稱前綴 + 起始自增數(shù)字 => prefix + start,下一個(gè)創(chuàng)建的協(xié)程名稱就是prefix + (start + 1)
            // start > 0的情況下會(huì)覆蓋name屬性配置
            .name("fiber-", 1L)
            // 是否啟用ThreadLocal
            .allowSetThreadLocals(false)
            // 是否啟用InheritableThreadLocal
            .inheritInheritableThreadLocals(false)
            // 設(shè)置調(diào)度器,Executor實(shí)例,也就是調(diào)度器是一個(gè)線程池,設(shè)置為NULL會(huì)使用VirtualThread.DEFAULT_SCHEDULER
            .scheduler(null)
            // 設(shè)置未捕獲異常處理器
            .uncaughtExceptionHandler(new Thread.UncaughtExceptionHandler() {
                @Override
                public void uncaughtException(Thread t, Throwable e) {

                }
            });
    // fiber-1
    Thread firstFiber = virtualThreadBuilder.unstarted(() -> System.out.println("Hello Platform Virtual First"));
    // fiber-2
    Thread secondFiber = virtualThreadBuilder.unstarted(() -> System.out.println("Hello Platform Virtual Second"));
}

這里可以發(fā)現(xiàn)一點(diǎn),就是建造器是可以復(fù)用的。如果想用建造器創(chuàng)建同一批參數(shù)設(shè)置相同的線程或者協(xié)程,可以設(shè)置name(String prefix, long start)方法,定義線程或者協(xié)程的名稱前綴和一個(gè)大于等于0的數(shù)字,反復(fù)調(diào)用Builder#unstarted(Runnable task)方法就能批量創(chuàng)建線程或者協(xié)程,名稱就設(shè)置為prefix + start、prefix + (start + 1)prefix + (start + 2)以此類推。協(xié)程創(chuàng)建基本就是這么簡(jiǎn)單,運(yùn)行的話直接調(diào)用start()方法:

public class FiberSample2 {

    public static void main(String[] args) throws Exception {
        Thread.ofVirtual()
                .name("fiber-1")
                .allowSetThreadLocals(false)
                .inheritInheritableThreadLocals(false)
                .unstarted(() -> {
                    Thread fiber = Thread.currentThread();
                    System.out.printf("[%s,daemon:%s,virtual:%s] - Hello World\n", fiber.getName(),
                            fiber.isDaemon(), fiber.isVirtual());
                }).start();
        // 主線程休眠
        Thread.sleep(Long.MAX_VALUE);
    }
}

目前無法在主流IDE編譯上面的類,所以只能使用該JDK目錄下的工具編譯和運(yùn)行,具體如下:

# 執(zhí)行 - 當(dāng)前目錄I:\J-Projects\framework-source-code\fiber-sample\src\main\java
(1)編譯:I:\Environment\Java\jdk-18-loom\bin\javac.exe I:\J-Projects\framework-source-code\fiber-sample\src\main\java\cn\throwx\fiber\sample\FiberSample2.java
(2)執(zhí)行main方法:I:\Environment\Java\jdk-18-loom\bin\java.exe  cn.throwx.fiber.sample.FiberSample2

這里也看出了一點(diǎn),所有的協(xié)程實(shí)例的daemon標(biāo)識(shí)默認(rèn)為true且不能修改。

小結(jié)

如果用嘗鮮的角度去使用Loom項(xiàng)目,可以提前窺探JVM開發(fā)者們是如何基于協(xié)程這個(gè)重大特性進(jìn)行開發(fā)的,這對(duì)于提高學(xué)習(xí)JDK內(nèi)核代碼的興趣有不少幫助。從目前來看,對(duì)于協(xié)程的實(shí)現(xiàn)Loom項(xiàng)目距離RELEASE版本估計(jì)還有不少功能需要完善,包括新增API的穩(wěn)定性,以及協(xié)程是否能夠移植到原有的JUC類庫(kù)中使用(當(dāng)前的Loom-JDK-18+9沒有對(duì)原來的線程池等類庫(kù)進(jìn)行修改)等問題需要解決,所以在保持關(guān)注的過程中靜心等待吧。

到此這篇關(guān)于Java協(xié)程編程之Loom項(xiàng)目嘗鮮的文章就介紹到這了,更多相關(guān)Java Loom項(xiàng)目?jī)?nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • SpringBoot深入分析講解監(jiān)聽器模式上

    SpringBoot深入分析講解監(jiān)聽器模式上

    監(jiān)聽器模式,大家應(yīng)該并不陌生,主要的組成要素包括了事件、監(jiān)聽器以及廣播器;當(dāng)事件發(fā)生時(shí),廣播器負(fù)責(zé)將事件傳遞給所有已知的監(jiān)聽器,而監(jiān)聽器會(huì)對(duì)自己感興趣的事件進(jìn)行處理
    2022-07-07
  • 如何使用Docker部署Java項(xiàng)目

    如何使用Docker部署Java項(xiàng)目

    在接觸了docker后,干什么都想用docker來弄,這篇文章主要給大家介紹了關(guān)于如何使用Docker部署Java項(xiàng)目的相關(guān)資料,文中通過圖文介紹的非常詳細(xì),需要的朋友可以參考下
    2023-07-07
  • java8新特性之Optional的深入解析

    java8新特性之Optional的深入解析

    這篇文章主要給大家介紹了關(guān)于java8新特性之Optional的相關(guān)資料,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面來一起學(xué)習(xí)學(xué)習(xí)吧
    2019-02-02
  • spring mvc @PathVariable綁定URI模板變量值方式

    spring mvc @PathVariable綁定URI模板變量值方式

    這篇文章主要介紹了spring mvc @PathVariable綁定URI模板變量值方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2021-11-11
  • Java使用quartz實(shí)現(xiàn)定時(shí)任務(wù)示例詳解

    Java使用quartz實(shí)現(xiàn)定時(shí)任務(wù)示例詳解

    這篇文章主要為大家介紹了Java使用quartz實(shí)現(xiàn)定時(shí)任務(wù)示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2022-08-08
  • Java實(shí)現(xiàn)線程同步的四種方式總結(jié)

    Java實(shí)現(xiàn)線程同步的四種方式總結(jié)

    Java線程同步屬于Java多線程與并發(fā)編程的核心點(diǎn),需要重點(diǎn)掌握,下面我就來詳解Java線程同步的4種主要的實(shí)現(xiàn)方式,需要的可以參考一下
    2022-09-09
  • 詳解IntelliJ IDEA 快捷鍵整合(大全)

    詳解IntelliJ IDEA 快捷鍵整合(大全)

    這篇文章主要介紹了詳解IntelliJ IDEA 快捷鍵整合,小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧
    2019-08-08
  • Java利用Geotools實(shí)現(xiàn)不同坐標(biāo)系之間坐標(biāo)轉(zhuǎn)換

    Java利用Geotools實(shí)現(xiàn)不同坐標(biāo)系之間坐標(biāo)轉(zhuǎn)換

    GeoTools 是一個(gè)開源的 Java GIS 工具包,可利用它來開發(fā)符合標(biāo)準(zhǔn)的地理信息系統(tǒng)。本文將利用工具包Geotools實(shí)現(xiàn)不同坐標(biāo)系之間坐標(biāo)轉(zhuǎn)換,感興趣的可以了解一下
    2022-08-08
  • Spring Boot 日志配置方法(超詳細(xì))

    Spring Boot 日志配置方法(超詳細(xì))

    默認(rèn)情況下,Spring Boot會(huì)用Logback來記錄日志,并用INFO級(jí)別輸出到控制臺(tái)。下面通過本文給大家介紹Spring Boot 日志配置方法詳解,感興趣的朋友參考下吧
    2017-07-07
  • Java JVM虛擬機(jī)運(yùn)行機(jī)制

    Java JVM虛擬機(jī)運(yùn)行機(jī)制

    JVM(Java虛擬機(jī))一種用于計(jì)算設(shè)備的規(guī)范,可用不同的方式(軟件或硬件)加以實(shí)現(xiàn)。接下來通過本文給大家簡(jiǎn)單介紹Java JVM虛擬機(jī)運(yùn)行機(jī)制,感興趣的朋友一起看看吧
    2017-03-03

最新評(píng)論