Java 21 的虛擬線程（Virtual Threads）讓“一個(gè)請(qǐng)求一個(gè)線程”重新變得可行。相比傳統(tǒng)平臺(tái)線程，虛擬線程更輕量、創(chuàng)建成本更低、阻塞代價(jià)更小，非常適合 I/O 密集型、高并發(fā)、請(qǐng)求生命周期短的服務(wù)。

但虛擬線程并不是“開了就快”，想真正發(fā)揮價(jià)值，必須理解它的適用邊界、調(diào)度特性和最佳實(shí)踐。本文結(jié)合代碼示例和性能對(duì)比，帶你從“能用”走到“用對(duì)”。

1. 虛擬線程是什么

虛擬線程由 JVM 管理，底層由少量載體線程（Carrier Threads）執(zhí)行。它的核心優(yōu)勢(shì)是：

• 創(chuàng)建和銷毀成本極低
• 可承載海量并發(fā)任務(wù)
• 在阻塞 I/O 場(chǎng)景下不會(huì)像平臺(tái)線程那樣迅速耗盡資源
• 更適合讓代碼保持同步寫法，降低回調(diào)地獄和復(fù)雜異步鏈路

你可以把它理解為：線程仍然是線程，但“重量”被 JVM 接管了。

2. 什么時(shí)候適合用虛擬線程

虛擬線程特別適合以下場(chǎng)景：

• Web 服務(wù)請(qǐng)求處理
• 調(diào)用數(shù)據(jù)庫、Redis、HTTP 接口等 I/O 密集型任務(wù)
• 大量短生命周期任務(wù)并發(fā)執(zhí)行
• 希望保留同步編程模型，但又需要高并發(fā)能力

不太適合：

• CPU 密集型計(jì)算任務(wù)
• 依賴線程本地狀態(tài)且設(shè)計(jì)混亂的老代碼
• 長時(shí)間占用鎖、頻繁做阻塞式同步等待的場(chǎng)景

3. 虛擬線程創(chuàng)建示例

示例 1：最簡單的虛擬線程創(chuàng)建

public class VirtualThreadDemo {
    public static void main(String[] args) throws InterruptedException {
        Thread vt = Thread.ofVirtual().start(() -> {
            System.out.println("Hello from virtual thread: " + Thread.currentThread());
        });

        vt.join();
    }
}

這段代碼與普通線程寫法幾乎一致，只是把 Thread.ofPlatform() 換成了 Thread.ofVirtual()。

示例 2：使用虛擬線程執(zhí)行多個(gè)任務(wù)

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

public class VirtualThreadExecutorDemo {
    public static void main(String[] args) throws InterruptedException {
        try (ExecutorService executor = Executors.newVirtualThreadPerTaskExecutor()) {
            for (int i = 0; i < 10; i++) {
                int taskId = i;
                executor.submit(() -> {
                    System.out.println("Task " + taskId + " running on " + Thread.currentThread());
                    TimeUnit.MILLISECONDS.sleep(200);
                    return null;
                });
            }
        }
    }
}

newVirtualThreadPerTaskExecutor() 是最推薦的入口之一。它保留了熟悉的 ExecutorService 模型，同時(shí)讓每個(gè)任務(wù)都運(yùn)行在虛擬線程上。

4. 最佳實(shí)踐：優(yōu)先把“阻塞型業(yè)務(wù)”遷移到虛擬線程

如果你的服務(wù)中存在大量如下代碼：

• JDBC 查詢
• HTTP 調(diào)用
• 文件讀寫
• RPC 請(qǐng)求

那么虛擬線程能顯著簡化并發(fā)模型。你可以繼續(xù)使用同步 API，而不必強(qiáng)行改造成復(fù)雜的響應(yīng)式鏈路。

推薦做法

• 保留同步代碼風(fēng)格，避免過度抽象
• 任務(wù)粒度盡量清晰，避免一個(gè)虛擬線程里做過多雜事
• 對(duì)外部依賴設(shè)置合理超時(shí)，避免虛擬線程堆積
• 結(jié)合連接池、限流和熔斷控制下游壓力

5. 最佳實(shí)踐：謹(jǐn)慎使用線程池的舊思維

虛擬線程時(shí)代，很多舊習(xí)慣需要更新。

不建議

• 繼續(xù)用大而重的平臺(tái)線程池去“模擬高并發(fā)”
• 為每類任務(wù)手工維護(hù)復(fù)雜線程池參數(shù)
• 盲目追求線程數(shù)越多越好

更合理的方式

• 對(duì)短任務(wù)使用虛擬線程 per task 模型
• 用信號(hào)量、限流器控制并發(fā)上限
• 用結(jié)構(gòu)化并發(fā)管理一組相關(guān)任務(wù)

6. 性能對(duì)比示例：平臺(tái)線程 vs 虛擬線程

下面用一個(gè)簡單的 I/O 模擬任務(wù)來對(duì)比二者差異。注意，這不是嚴(yán)格基準(zhǔn)測(cè)試，但足以說明趨勢(shì)。

示例 3：性能對(duì)比代碼

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

public class ThreadCompareDemo {
    private static final int TASKS = 10_000;

    public static void main(String[] args) throws Exception {
        long platformTime = runPlatformThreads();
        long virtualTime = runVirtualThreads();

        System.out.println("Platform threads cost: " + platformTime + " ms");
        System.out.println("Virtual threads cost:  " + virtualTime + " ms");
    }

    static long runPlatformThreads() throws Exception {
        long start = System.currentTimeMillis();
        try (ExecutorService executor = Executors.newFixedThreadPool(200)) {
            List<java.util.concurrent.Future<?>> futures = new ArrayList<>();
            for (int i = 0; i < TASKS; i++) {
                futures.add(executor.submit(() -> {
                    TimeUnit.MILLISECONDS.sleep(10);
                    return null;
                }));
            }
            for (var f : futures) {
                f.get();
            }
        }
        return System.currentTimeMillis() - start;
    }

    static long runVirtualThreads() throws Exception {
        long start = System.currentTimeMillis();
        try (ExecutorService executor = Executors.newVirtualThreadPerTaskExecutor()) {
            List<java.util.concurrent.Future<?>> futures = new ArrayList<>();
            for (int i = 0; i < TASKS; i++) {
                futures.add(executor.submit(() -> {
                    TimeUnit.MILLISECONDS.sleep(10);
                    return null;
                }));
            }
            for (var f : futures) {
                f.get();
            }
        }
        return System.currentTimeMillis() - start;
    }
}

結(jié)果解讀

在 I/O 等待占主導(dǎo)的場(chǎng)景下，虛擬線程通常能以更少的資源支撐更高并發(fā)。平臺(tái)線程池會(huì)受到線程數(shù)量和上下文切換成本影響，而虛擬線程可以更自然地?cái)U(kuò)展到海量任務(wù)。

但要注意：虛擬線程提升的是并發(fā)吞吐和資源利用率，不會(huì)讓 CPU 密集型任務(wù)憑空變快。

7. 最佳實(shí)踐：避免“載體線程阻塞”問題

虛擬線程雖然輕量，但如果你在其中調(diào)用了某些會(huì)長期占用載體線程的操作，收益會(huì)下降。

例如：

• 在同步塊中執(zhí)行長時(shí)間阻塞操作
• 使用不兼容虛擬線程的老舊 native 調(diào)用
• 依賴線程綁定資源但不做重構(gòu)

建議：

• 縮小 synchronized 范圍
• 優(yōu)先使用更現(xiàn)代的并發(fā)工具
• 對(duì)第三方庫做兼容性驗(yàn)證

8. 最佳實(shí)踐：結(jié)合結(jié)構(gòu)化并發(fā)提升可維護(hù)性

Java 21 還帶來了結(jié)構(gòu)化并發(fā)的預(yù)覽特性，它和虛擬線程是天然搭檔。

當(dāng)一個(gè)請(qǐng)求需要并行調(diào)用多個(gè)下游服務(wù)時(shí)，結(jié)構(gòu)化并發(fā)可以讓任務(wù)管理更清晰：

• 統(tǒng)一啟動(dòng)、統(tǒng)一等待
• 任一子任務(wù)失敗可快速取消其他任務(wù)
• 代碼層次更清晰，錯(cuò)誤處理更集中

這比手寫一堆 Future 聚合邏輯更易維護(hù)。

9. 落地建議：從一個(gè)入口開始改造

如果你正在把傳統(tǒng) Java 服務(wù)遷移到虛擬線程，建議按以下步驟推進(jìn)：

1. 先挑選 I/O 密集型接口
2. 使用 newVirtualThreadPerTaskExecutor() 替換舊線程池
3. 保持同步寫法，不急于重構(gòu)業(yè)務(wù)邏輯
4. 加上超時(shí)、限流、熔斷
5. 觀察 CPU、內(nèi)存、延遲和下游壓力
6. 再逐步擴(kuò)展到更多鏈路

10. 總結(jié)

Java 21 虛擬線程的最大價(jià)值，不是“替代所有線程池”，而是讓高并發(fā)服務(wù)重新回到更簡單、更自然的同步編程模型。

記住這幾個(gè)關(guān)鍵詞：

• I/O 密集型優(yōu)先
• 同步代碼更易遷移
• 配合限流與超時(shí)控制
• 關(guān)注下游和載體線程阻塞
• 結(jié)構(gòu)化并發(fā)讓復(fù)雜任務(wù)更可控

如果你想用更低的復(fù)雜度獲得更高的并發(fā)能力，虛擬線程是 Java 21 時(shí)代值得優(yōu)先嘗試的技術(shù)方案。

到此這篇關(guān)于Java 21 虛擬線程最佳實(shí)踐的文章就介紹到這了,更多相關(guān)Java 21 虛擬線程內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論