Java 異步編程實踐_動力節(jié)點Java學(xué)院整理
什么是異步?為什么要用它?
異步編程提供了一個非阻塞的,事件驅(qū)動的編程模型。 這種編程模型利用系統(tǒng)中多核執(zhí)行任務(wù)來提供并行,因此提供了應(yīng)用的吞吐率。此處吞吐率是指在單位時間內(nèi)所做任務(wù)的數(shù)量。 在這種編程方式下, 一個工作單元將獨立于主應(yīng)用線程而執(zhí)行, 并且會將它的狀態(tài)通知調(diào)用線程:成功,處理中或者失敗。
我們需要異步來消除阻塞模型。其實異步編程模型可以使用同樣的線程來處理多個請求, 這些請求不會阻塞這個線程。想象一個應(yīng)用正在使用的線程正在執(zhí)行任務(wù), 然后等待任務(wù)完成才進行下一步。 log框架就是一個很好的例子:典型地你想將異常和錯誤日志記錄到一個目標(biāo)中, 比如文件,數(shù)據(jù)庫或者其它類似地方。你不會讓你的程序等待日志寫完才執(zhí)行,否則程序的響應(yīng)就會受到影響。 相反,如果對log框架的調(diào)用是異步地,應(yīng)用就可以并發(fā)執(zhí)行其它任務(wù)而無需等待。這是一個非阻塞執(zhí)行的例子。
為了在Java中實現(xiàn)異步,你需要使用Future 和 FutureTask, 它們位于java.util.concurrent包下. Future是一個接口而FutureTask是它的一個實現(xiàn)類。實際上,如果在你的代碼中使用Future, 你的異步任務(wù)會立即執(zhí)行, 并且調(diào)用線程可以得到結(jié)果promise。
下面的代碼片段定義了一個包含兩個方法的接口。 一個是同步方法,另外一個是異步方法。
import java.util.concurrent.Future; public interface IDataManager { // synchronous method public String getDataSynchronously(); // asynchronous method public Future<String> getDataAsynchronously(); }
值得注意的是回調(diào)模型的弊端就是當(dāng)回調(diào)嵌套時很麻煩。
該做和不該做的
為了方便測試, 你應(yīng)該在代碼中將功能從多線程中隔離出來。當(dāng)在Java中編寫異步代碼時,你應(yīng)該遵循異步模型,這樣調(diào)用線程就不會被阻塞。
注意構(gòu)造函數(shù)不能是異步的,你不應(yīng)該在構(gòu)造函數(shù)中調(diào)用異步方法。當(dāng)任務(wù)互相不依賴時異步方式尤其有用。當(dāng)調(diào)用任務(wù)依賴被調(diào)用任務(wù)時不應(yīng)該使用異步(譯者按:這對異步來說無意義,因為業(yè)務(wù)上調(diào)用線程被阻塞了).
你應(yīng)該在異步方法中處理異常. 你不應(yīng)該為長時間的task實現(xiàn)異常. 一個長時間運行的任務(wù),如果異步執(zhí)行的話, 可能會比同步執(zhí)行耗費更長的時間, 因為運行時要為異步執(zhí)行的方法執(zhí)行線程上下文的切換, 線程狀態(tài)的存儲等. 你也應(yīng)該注意同步的異常和異步的異常有所不同。 同步異常暗示 每次程序執(zhí)行到那個程序特殊狀態(tài)時就會拋出異常;異步異常的跟蹤則困難的多。所以同步和異步異常暗示同步或異步代碼可能拋出異常(synchronous and asynchronous exceptions imply synchronous or asynchronous code in your program that might raise exceptions.)。
總結(jié)
異步對于設(shè)計大規(guī)??焖夙憫?yīng)的應(yīng)用是至關(guān)重要的。異步回調(diào)模型帶來了很多的好處;你可以依賴你的異步回調(diào)方法來執(zhí)行昂貴的I/O操作而你的處理器可以執(zhí)行其它任務(wù)。然而雖然在Java和C#中提供了異步的支持,異步編程并不總是那么容易實現(xiàn)。異步方式的使用要謹(jǐn)慎: 你應(yīng)該清楚什么時候可以用和什么時候不該用。
本文中我們介紹了異步編程的概念, 以及使用Java編程需要怎么去實現(xiàn). 本文也列出了使用異步編程的最佳實踐。謝謝閱讀。
Java 7中提供了Fork/Join框架, 可以將一個大的task分割成很多可以并行執(zhí)行的小task。Java 8中parallelStream內(nèi)部利用Fork/Join執(zhí)行并發(fā)操作。
像Node.js天生支持異步編程模式, 其它語言如golang使用 goroutines 和 channels.也很容易實現(xiàn)異步。
相關(guān)文章
Mybatis 動態(tài)表名+Map參數(shù)傳遞+批量操作詳解
這篇文章主要介紹了Mybatis 動態(tài)表名+Map參數(shù)傳遞+批量操作詳解,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2020-12-12springboot內(nèi)置tomcat調(diào)優(yōu)并發(fā)線程數(shù)解析
這篇文章主要介紹了springboot內(nèi)置tomcat調(diào)優(yōu)并發(fā)線程數(shù)解析,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2021-12-12一篇文章教你將JAVA的RabbitMQz與SpringBoot整合
這篇文章主要介紹了如何將JAVA的RabbitMQz與SpringBoot整合,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧2021-09-09Windows安裝Maven并配置環(huán)境的詳細步驟
Maven是一個非常流行的構(gòu)建和項目管理工具,用于Java開發(fā),它提供了一個強大的依賴管理系統(tǒng)和一系列標(biāo)準(zhǔn)化的構(gòu)建生命周期,本文將指導(dǎo)您如何在Windows操作系統(tǒng)上安裝和配置Maven,需要的朋友可以參考下2023-05-05深入理解SpringMVC的參數(shù)綁定與數(shù)據(jù)響應(yīng)機制
本文將深入探討SpringMVC的參數(shù)綁定方式,包括基本類型、對象、集合等類型的綁定方式,以及如何處理參數(shù)校驗和異常。同時,本文還將介紹SpringMVC的數(shù)據(jù)響應(yīng)機制,包括如何返回JSON、XML等格式的數(shù)據(jù),以及如何處理文件上傳和下載。2023-06-06