Project Loom通過虛擬線程使封鎖操作廉價(jià)，從而減少了反應(yīng)性編程的需求，從而使簡單的同步代碼能夠有效地?cái)U(kuò)展。 2。反應(yīng)性編程與背壓處理，大量或無限數(shù)據(jù)流以及復(fù)雜的異步組成保持一致。 3。虛擬線程在I/O界中出色，用可讀的代碼阻止場景，而反應(yīng)性模式仍然是細(xì)粒度控制，流處理和無織機(jī)環(huán)境的首選。 4。兩者可以共存，反應(yīng)性管道在虛擬線程上運(yùn)行或使用虛擬線索調(diào)度程序，結(jié)合簡單和控制。 5。默認(rèn)情況下，Java并發(fā)的未來有利于簡單的阻止代碼，僅在需要其高級功能時使用反應(yīng)性方法，這意味著反應(yīng)堆或WebFlux（例如反應(yīng)器或Webflux）不陳詞濫調(diào)，但應(yīng)明智地使用。

傳統(tǒng)上，Java中的反應(yīng)性編程依賴于項(xiàng)目反應(yīng)堆或RXJAVA等庫來處理異步，非阻滯操作，尤其是在高恒定場景中，例如Web服務(wù)器或事件驅(qū)動的系統(tǒng)。但是，隨著項(xiàng)目織機(jī)和虛擬線程在Java 21中的到來，并發(fā)編程的景觀正在急劇轉(zhuǎn)移。這提出了一個重要的問題：項(xiàng)目織機(jī)如何影響Java中的反應(yīng)性編程？

簡短的答案：虛擬線程減少了許多常見用例中反應(yīng)性編程的需求，但是反應(yīng)性模式仍然具有其位置，尤其是在處理背壓，復(fù)雜的數(shù)據(jù)流或功能組成時。

讓我們分解一下。

1。反應(yīng)性編程解決了什么問題？

在織機(jī)之前，使用傳統(tǒng)阻塞I/O處理數(shù)千個并發(fā)請求（例如JDBC， Thread.sleep()或阻止HTTP調(diào)用）很昂貴。每個線程都消耗了重要的內(nèi)存（默認(rèn)情況下為1MB堆棧），并且OS在線程計(jì)數(shù)上有限制。

因此，出現(xiàn)了反應(yīng)器和WebFlux等反應(yīng)性框架：

• 使用非阻滯I/O和事件循環(huán)（例如Node.js）。
• 在許多任務(wù)上共享少數(shù)線程。
• 將數(shù)據(jù)作為流進(jìn)行處理，諸如map ， filter ， flatMap類的操作員。
• 支持背壓- 消費(fèi)者可以控制數(shù)據(jù)流的速率。

該模型運(yùn)行良好，但復(fù)雜性很復(fù)雜：

• 陡峭的學(xué)習(xí)曲線。
• 更難的調(diào)試（堆棧痕跡被分散）。
• 與阻塞API的互操作性有限。

2。項(xiàng)目織機(jī)如何改變游戲

Project Loom介紹了虛擬線程- JVM管理的LightSemake Weights線程，而不是OS。

關(guān)鍵好處：

• 數(shù)百萬個虛擬線程可以有效地運(yùn)行。
• 每個虛擬線程使用的內(nèi)存少得多（?數(shù)百個字節(jié)）。
• 它們設(shè)計(jì)為廉價(jià)地阻止。是的，封鎖現(xiàn)在還可以。

例子：

 executorService executor = executors.newvirtualThreadPertasKexeCutor（）;

intstream.range（0，10_000）.foreach（i-> {
    executor.submit（（） - > {
        thread.sleep（持續(xù)時間。
        system.out.println（“完成：” i）;
        返回null;
    }）;
}）;

這會產(chǎn)生10,000個虛擬線，而無需殺死您的系統(tǒng)。使用平臺線程，這將失敗或爬網(wǎng)。

因此，現(xiàn)在，您可以編寫簡單的，同步的代碼來縮放尺度，而不是編寫復(fù)雜的反應(yīng)鏈以避免阻塞。

3。這會使反應(yīng)性編程過時嗎？

并非完全。這是每種方法的亮點(diǎn)：

?使用虛擬線程：

• 您正在進(jìn)行I/O-BOND工作（例如，HTTP調(diào)用，文件操作）。
• 您需要簡單，可讀的代碼。
• 您不需要背壓或流處理。
• 您正在與阻止API（例如傳統(tǒng)JDBC）集成。

 void handlerequest（）{
    var用戶= db.loaduser（）; //阻止
    var config = service.getConfig（）; //阻止http
    emailService.Send（用戶，config）;
}

每個虛擬線程中運(yùn)行其中一個 - 無需Mono ， Flux或回調(diào)地獄。

?在以下情況時保持反應(yīng)性編程

• 您需要背壓（例如，快速生產(chǎn)者，緩慢的消費(fèi)者）。
• 您正在處理無限或大量數(shù)據(jù)流。
• 您需要對調(diào)度和線程的細(xì)粒度控制。
• 您處于無法使用織機(jī)（較舊的Java版本）的環(huán)境中。
• 您依靠反應(yīng)性生態(tài)系統(tǒng)（例如Spring WebFlux，R2DBC）。

反應(yīng)性仍然擅長組成異步操作和在極端負(fù)載下管理資源使用情況。

4。他們可以一起工作嗎？

是的 - 有時候這是最好的方法。

您可以在虛擬線程中運(yùn)行反應(yīng)性管道，也可以將虛擬線程用作反應(yīng)性任務(wù)的執(zhí)行目標(biāo)。

例如：

 mono.fromcallable（（（） - >非常便宜的blockingoperation（））
    。
        執(zhí)行者.newvirtualthreadpertaskexecutor（）
    ）;

現(xiàn)在，您的反應(yīng)流通過虛擬線程受益于廉價(jià)阻止。

或者，在Spring Boot 6中使用項(xiàng)目反應(yīng)器與虛擬線程使用：

 @豆
公共調(diào)度程序VirtualThreadScheduler（）{
    返回調(diào)度程序。fromexecutor（executors.newvirtualthreadpertaskexecutor（））;
}

然后：

單聲道（“ Hello”）
    .publishon（VirtualThreadScheduler（））
    .map（this :: blockingtransform）
    。訂閱（）;

這種混合模型為您提供了兩全其美的最好：反應(yīng)流控制，并具有織機(jī)的并發(fā)效率。

底線

• Project Loom不會殺死反應(yīng)性編程- 它重新定義了其作用。
• 對于大多數(shù)常規(guī)的服務(wù)器應(yīng)用程序，虛擬線程使簡單的阻止代碼可擴(kuò)展，從而降低了反應(yīng)性復(fù)雜性的需求。
• 反應(yīng)性編程對于高級流處理，背壓以及與反應(yīng)性系統(tǒng)的集成仍然有價(jià)值。
• 未來可能是“在需要時反應(yīng)性的，默認(rèn)情況下很簡單”。

那么，您應(yīng)該停止使用反應(yīng)堆或WebFlux嗎？不，但是重新考慮如果您使用它們只是為了避免用線耗盡。對于織機(jī)，該問題在很大程度上得到了解決。

基本上：首先編寫簡單的代碼。僅當(dāng)您需要其獨(dú)特的力量時才能獲得反應(yīng)性。

以上是帶有項(xiàng)目織機(jī)和虛擬線程的Java中的反應(yīng)性編程的詳細(xì)內(nèi)容。更多信息請關(guān)注PHP中文網(wǎng)其他相關(guān)文章！