Java協程編程之Loom
Java協程編程Loom
前提：
OpenJDK給出的官網https://openjdk.java.net/projects/loom有少量Loom項目相關的信息）JDK17編譯和JDK18編譯等早期版本，Loom早期版本JDK18編譯的版本：下載入口在：https://jdk.java.net/loom
由于該JDK版本過高，目前可以使用主流IDE導入Loom-JDK-18+9進行代碼高亮和語法提醒，暫時找不到方法進行編譯，暫時使用該JDK執(zhí)行目錄下的的javac命令腳本進行編譯，使用java命令腳本運行。
1、Loom項目簡單介紹
Loom - Fibers, Continuations and Tail-Calls for the JVM
Loom項目的標題已經凸顯了引入的三大新特性：
Fibers：幾年前看過當時的Loom項目的測試代碼就是使用Fiber這個API（現在這個API已經被移除），意為輕量級線程，即協程，又稱為輕量級用戶線程，很神奇的是在目前的JDK中實際上稱為Virtual Thread（虛擬線程）Continuations：直譯為"連續(xù)"，實現上有點像閉包，參考不少資料，尚未準確理解其具體含義，感覺可以"粗暴"解讀為"程序接下來要執(zhí)行什么"或者"下一個要執(zhí)行的代碼塊"Tail-Calls：尾調用VM級別支持
三個新特性不詳細展開，目前只是EA版本，還存在修改的可能性，所以也沒必要詳細展開。
2、Virtual Thread使用
當前版本Loom項目中協程使用并沒有引入一個新的公開的虛擬線程VirtualThread類，雖然真的存在VirtualThread，但這個類使用default修飾符，隱藏在java.lang包中，并且VirtualThread是Thread的子類。協程的創(chuàng)建API位于Thread類中：
使用此API創(chuàng)建協程如下：
public static void main(String[] args) {
Thread fiber = Thread.startVirtualThread(() -> System.out.println("Hello Fiber"));
}
從當前的源碼可知：
VirtualThread會通過Thread.currentThread()獲取父線程的調度器，如果在main方法運行，那么上面代碼中的協程實例的父線程就是main線程- 默認的調度器為系統創(chuàng)建的
ForkJoinPool實例（VirtualThread.DEFAULT_SCHEDULER），輸入的Runnable實例會被封裝為RunContinuation，最終由調度器執(zhí)行 - 對于
timed unpark（正在阻塞，等待喚醒）的協程，使用系統創(chuàng)建的ScheduledExecutorService實例進行喚醒 - 這個靜態(tài)工廠方法創(chuàng)建完協程馬上運行，返回的是協程實例
如果按照上面的Thread.startVirtualThread()方法去創(chuàng)建協程，顯然無法定義協程的名稱等屬性。Loom項目為Thread類引入了建造者模式，比較合理地解決了這個問題：
// 創(chuàng)建平臺線程建造器，對應于Thread實例
public static Builder.OfPlatform ofPlatform() {
return new ThreadBuilders.PlatformThreadBuilder();
}
// 創(chuàng)建虛擬線程建造器，對應于VirtualThread
public static Builder.OfVirtual ofVirtual() {
return new ThreadBuilders.VirtualThreadBuilder();
}
簡單說就是：
ofPlatform()方法用于構建Thread實例，這里的Platform Thread（平臺線程）其實就是JDK1.0引入的線程實例，普通的用戶線程
ofVirtual()方法用于構建VirtualThread實例，也就是構建協程實例
這兩個建造器實例的所有Setter方法鏈展開如下：
public static void main(String[] args) {
Thread.Builder.OfPlatform platformThreadBuilder = Thread.ofPlatform()
// 是否守護線程
.daemon(true)
// 線程組
.group(Thread.currentThread().getThreadGroup())
// 線程名稱
.name("thread-1")
// 線程名稱前綴 + 起始自增數字 => prefix + start,下一個創(chuàng)建的線程名稱就是prefix + (start + 1)
// start > 0的情況下會覆蓋name屬性配置
.name("thread-", 1L)
// 是否啟用ThreadLocal
.allowSetThreadLocals(false)
// 是否啟用InheritableThreadLocal
.inheritInheritableThreadLocals(false)
// 設置優(yōu)先級
.priority(100)
// 設置線程棧深度
.stackSize(10)
// 設置未捕獲異常處理器
.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()
// 協程名稱
.name("fiber-1")
// 協程名稱前綴 + 起始自增數字 => prefix + start,下一個創(chuàng)建的協程名稱就是prefix + (start + 1)
// start > 0的情況下會覆蓋name屬性配置
.name("fiber-", 1L)
// 是否啟用ThreadLocal
.allowSetThreadLocals(false)
// 是否啟用InheritableThreadLocal
.inheritInheritableThreadLocals(false)
// 設置調度器,Executor實例,也就是調度器是一個線程池,設置為NULL會使用VirtualThread.DEFAULT_SCHEDULER
.scheduler(null)
// 設置未捕獲異常處理器
.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ā)現一點，就是建造器是可以復用的。如果想用建造器創(chuàng)建同一批參數設置相同的線程或者協程，可以設置name(String prefix, long start)方法，定義線程或者協程的名稱前綴和一個大于等于0的數字，反復調用Builder#unstarted(Runnable task)方法就能批量創(chuàng)建線程或者協程，名稱就設置為prefix + start、prefix + (start + 1)、prefix + (start + 2)以此類推。協程創(chuàng)建基本就是這么簡單，運行的話直接調用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目錄下的工具編譯和運行，具體如下：
# 執(zhí)行 - 當前目錄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
這里也看出了一點，所有的協程實例的daemon標識默認為true且不能修改
以上就是Java協程編程之Loom的詳細內容，更多關于Java編程Loom的資料請關注腳本之家其它相關文章！
相關文章
本篇文章主要介紹了詳述 DB2 分頁查詢及 Java 實現的示例，具有一定的參考價值，感興趣的小伙伴們可以參考一下2017-09-09
KMP算法是一種神奇的字符串匹配算法，在對超長字符串進行模板匹配的時候比暴力匹配法的效率會高不少。本文將利用圖解為大家詳細講解KMP算法的實現，需要的可以參考一下2022-05-05
這篇文章主要介紹了java基于OpenGL ES實現渲染,實例分析了OpenGL渲染操作的相關技巧,需要的朋友可以參考下2015-06-06
Monaco?Editor實現sql和java代碼提示實現示例
這篇文章主要為大家介紹了Monaco?Editor代碼提示sql和java實現示例，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2022-08-08
本文主要介紹了Java中if語句return用法和有無括號的區(qū)別,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2023-12-12
以下是我整理的關于java中map的遍歷的四種方法。需要的朋友可以過來參考下，希望對大家有所幫助2013-10-10
httpclient 請求http數據,json轉map的實例
下面小編就為大家?guī)硪黄猦ttpclient 請求http數據,json轉map的實例。小編覺得挺不錯的，現在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2016-12-12
這篇文章主要介紹了Java信號量的相關資料，幫助大家更好的理解和使用Java，感興趣的朋友可以了解下2021-01-01
這篇文章詳細介紹了Java中Optional類的使用,包括創(chuàng)建Optional對象,Optional對象的常用方法,如get、orElse、orElseGet、orElseThrow等,以及Optional類結合Lambda表達式和StreamAPI的使用,需要的朋友可以參考下2024-10-10
這篇文章主要介紹了springboot過濾器和攔截器的實例代碼，代碼簡單易懂，對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2021-07-07