Java多線程實現(xiàn)異步調(diào)用的方法
在JAVA平臺,實現(xiàn)異步調(diào)用的角色有如下三個角色:調(diào)用者 提貨單 真實數(shù)據(jù)
一個調(diào)用者在調(diào)用耗時操作,不能立即返回數(shù)據(jù)時,先返回一個提貨單.然后在過一斷時間后憑提貨單來獲取真正的數(shù)據(jù).
去蛋糕店買蛋糕，不需要等蛋糕做出來（假設現(xiàn)做要很長時間），只需要領個提貨單就可以了（去干別的事情），等到蛋糕做好了，再拿提貨單取蛋糕就可以了。
public class Main {
public static void main(String[] args) {
System.out.println("main BEGIN");
Host host = new Host();
Data data1 = host.request(10, 'A');
Data data2 = host.request(20, 'B');
Data data3 = host.request(30, 'C');
System.out.println("main otherJob BEGIN");
try {
Thread.sleep(200);
} catch (InterruptedException e) {
}
System.out.println("main otherJob END");
System.out.println("data1 = " + data1.getContent());
System.out.println("data2 = " + data2.getContent());
System.out.println("data3 = " + data3.getContent());
System.out.println("main END");
}
}
這里的main類就相當于“顧客”，host就相當于“蛋糕店”，顧客向“蛋糕店”定蛋糕就相當于“發(fā)請求request”，返回的數(shù)據(jù)data是FutureData的實例，就相當于提貨單，而不是真正的“蛋糕”。在過一段時間后（sleep一段時間后），調(diào)用data1.getContent()，也就是拿提貨單獲取執(zhí)行結(jié)果。
下面來看一下，顧客定蛋糕后，蛋糕店做了什么：
public class Host {
public Data request(final int count, final char c) {
System.out.println("request(" + count + ", " + c + ") BEGIN");
// (1) 建立FutureData的實體
final FutureData future = new FutureData();
// (2) 為了建立RealData的實體，啟動新的線程
new Thread() {
public void run() {
//在匿名內(nèi)部類中使用count、future、c。
RealData realdata = new RealData(count, c);
future.setRealData(realdata);
}
}.start();
System.out.println("request(" + count + ", " + c + ") END");
// (3) 取回FutureData實體，作為傳回值
return future;
}
}
host("蛋糕店")在接到請求后，先生成了“提貨單”FutureData的實例future，然后命令“蛋糕師傅”RealData去做蛋糕，realdata相當于起個線程去做蛋糕了。然后host返回給顧客的僅僅是“提貨單”future，而不是蛋糕。當?shù)案庾龊煤?，蛋糕師傅才能給對應的“提貨單”蛋糕，也就是future.setRealData(realdata)。
下面來看看蛋糕師傅是怎么做蛋糕的：
建立一個字符串，包含count個c字符，為了表現(xiàn)出犯法需要花費一些時間，使用了sleep。
public class RealData implements Data {
private final String content;
public RealData(int count, char c) {
System.out.println("making RealData(" + count + ", " + c + ") BEGIN");
char[] buffer = new char[count];
for (int i = 0; i < count; i++) {
buffer[i] = c;
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
}
}
System.out.println("making RealData(" + count + ", " + c + ") END");
this.content = new String(buffer);
}
public String getContent() {
return content;
}
}
現(xiàn)在來看看“提貨單”future是怎么與蛋糕"content"對應的:
public class FutureData implements Data {
private RealData realdata = null;
private boolean ready = false;
public synchronized void setRealData(RealData realdata) {
if (ready) {
return; // 防止setRealData被調(diào)用兩次以上。
}
this.realdata = realdata;
this.ready = true;
notifyAll();
}
public synchronized String getContent() {
while (!ready) {
try {
wait();
} catch (InterruptedException e) {
}
}
return realdata.getContent();
}
}
顧客做完自己的事情后，會拿著自己的“提貨單”來取蛋糕：
System.out.println("data1 = " + data1.getContent());
這時候如果蛋糕沒做好，就只好等了：
while (!ready) {
try {
wait();
} catch (InterruptedException e) {
}
//等做好后才能取到
return realdata.getContent();
程序分析
對于每個請求，host都會生成一個線程，這個線程負責生成顧客需要的“蛋糕”。在等待一段時間以后，如果蛋糕還沒有做好，顧客還必須等待。直到“蛋糕被做好”，也就是future.setRealData(realdata); 執(zhí)行以后，顧客才能拿走蛋糕。
每個線程只是專門負責制作特定顧客所需要的“蛋糕”。也就是顧客A對應著蛋糕師傅A，顧客B對應著蛋糕師傅B。即使顧客B的蛋糕被先做好了，顧客A也只能等待蛋糕師傅A把蛋糕做好。換句話說，顧客之間沒有競爭關系。
類FutureData的兩個方法被設置為synchronized，實際上蛋糕師傅A與顧客A之間的互斥關系，也就是顧客A必須等待蛋糕師傅A把蛋糕做好后，才能拿走，而與蛋糕師傅B是否做好了蛋糕沒有關系。
本文內(nèi)容就到此全部結(jié)束了，代碼簡單吧，希望對大家學習Java多線程實現(xiàn)異步調(diào)用有所幫助，謝謝。
相關文章
這篇文章主要介紹了SpringCloud組件性能優(yōu)化的技巧,Springcloud?原始的配置,性能是很低的,大家可以使用?Jmeter?測試一下,QPS?不會到?50,要做到高并發(fā),需要做不少的配置優(yōu)化,需要的朋友可以參考下2023-09-09
Java實現(xiàn)批量向mysql寫入數(shù)據(jù)的方法
這篇文章主要介紹了Java實現(xiàn)批量向mysql寫入數(shù)據(jù)的方法,涉及java基于JDBC連接mysql數(shù)據(jù)庫及寫入數(shù)據(jù)的相關操作技巧,非常簡單實用,需要的朋友可以參考下2017-12-12
這篇文章主要介紹了SpringMVC的Dispatcher用法,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2023-11-11
負載均衡指由多臺服務器以對稱的方式組成一個服務器集合,每臺服務器都具有等價的地位,都可以單獨對外提供服務而無須其他服務器的輔助,這篇文章主要給大家介紹了關于使用Java實現(xiàn)5種負載均衡算法的相關資料,需要的朋友可以參考下2021-09-09
Spring?Boot深入學習數(shù)據(jù)訪問之Spring?Data?JPA與Hibernate的應用
Spring?Data?JPA是Spring?Data的子項目，在使用Spring?Data?JPA之前，先了解一下Hibernate，因為Spring?Data?JPA是由Hibernate默認實現(xiàn)的2022-10-10
靜態(tài)方法中調(diào)用Spring注入過程解析
這篇文章主要介紹了靜態(tài)方法中調(diào)用Spring注入過程解析,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2019-11-11
spring-boot-maven-plugin:unknown的完美解決方法
這篇文章主要介紹了spring-boot-maven-plugin:unknown的完美解決方法,本文通過圖文并茂的形式給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2020-11-11
Java流程控制之循環(huán)結(jié)構for,增強for循環(huán)
這篇文章主要介紹了Java流程控制之循環(huán)結(jié)構for,增強for循環(huán)，for循環(huán)是編程語言中一種循環(huán)語句，而循環(huán)語句由循環(huán)體及循環(huán)的判定條件兩部分組成，其表達式為：for（單次表達式;條件表達式;末尾循環(huán)體）{中間循環(huán)體；}，下面我們倆看看文章內(nèi)容的詳細介紹2021-12-12
java本機內(nèi)存分配Native?memory?allocation?mmap失敗問題解決
這篇文章主要介紹了java本機內(nèi)存分配Native?memory?allocation?mmap失敗問題解決,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-11-11
這篇文章主要介紹了淺談Spring 的Controller 是單例or多例，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2020-08-08