第七色在线视频,2021少妇久久久久久久久久,亚洲欧洲精品成人久久av18,亚洲国产精品特色大片观看完整版,孙宇晨将参加特朗普的晚宴

為了賬號(hào)安全,請(qǐng)及時(shí)綁定郵箱和手機(jī)立即綁定
已解決430363個(gè)問(wèn)題,去搜搜看,總會(huì)有你想問(wèn)的

在 Java 中如何等待所有異步調(diào)用完成?

在 Java 中如何等待所有異步調(diào)用完成?

ibeautiful 2021-09-26 14:29:44
概念上非常簡(jiǎn)單。我們有一個(gè)巨大的遺留 Java 站點(diǎn),它不使用線程/異步。登錄需要很長(zhǎng)時(shí)間,因?yàn)樗鼘?duì)不同的微服務(wù)進(jìn)行了十幾次調(diào)用,但每次都是同步調(diào)用:在進(jìn)行下一次調(diào)用之前,每個(gè)都等待另一個(gè)完成。但是,沒(méi)有一個(gè) API 調(diào)用依賴于任何其他調(diào)用的結(jié)果。但是在我們繼續(xù)之前,我們確實(shí)需要獲得所有結(jié)果并將它們組合起來(lái)。很明顯,我們應(yīng)該能夠并行進(jìn)行這十幾個(gè)調(diào)用,但要等待它們?nèi)客瓿梢栽谙乱徊街惺褂盟鼈兊臄?shù)據(jù)。所以在調(diào)用之前和之后一切都是同步的。然而,最好并行地、異步地——或者只是并行地——將它們各自發(fā)送出去——那么我們只受到單個(gè)最慢調(diào)用的限制,而不是所有調(diào)用的總連續(xù)時(shí)間。我讀到 Java 8 在CompletableFuture. 但我還沒(méi)有找到任何地方解釋我的用途。我們不希望結(jié)果成為一個(gè)承諾 - 我們很高興等到它們?nèi)客瓿扇缓罄^續(xù)。JS 有Promise.all(),但即使如此也會(huì)返回一個(gè)承諾。我能想到的就是在異步調(diào)用完成后稍作等待,只有在我們獲得所有結(jié)果后才繼續(xù)。這顯然是瘋了。我在這里錯(cuò)過(guò)了什么嗎?因?yàn)檫@對(duì)我來(lái)說(shuō)似乎很明顯,但似乎沒(méi)有其他人對(duì)此有疑問(wèn)——或者方法很簡(jiǎn)單,沒(méi)有人費(fèi)心去問(wèn),而我就是不明白。
查看完整描述

1 回答

?
智慧大石

TA貢獻(xiàn)1946條經(jīng)驗(yàn) 獲得超3個(gè)贊

如果我理解正確,你想要這樣的東西:


ExecutorService executorService = Executors.newFixedThreadPool(4); // TODO: proper number of threads


Future<Integer> future1 = executorService.submit(() -> callService1()); // TODO: proper type and method

Future<String> future2 = executorService.submit(() -> callService2()); // TODO: proper type and method


executorService.shutdown();

executorService.awaitTermination(5, TimeUnit.MINUTES); // TODO: proper timeout


Integer result1 = future1.get(); // TODO: proper type

String result2 = future2.get(); // TODO: proper type

解釋:

  • 上面的代碼創(chuàng)建了一個(gè)ExecutorService有 4 個(gè)線程的線程,您可以向其中提交所有任務(wù)(即調(diào)用微服務(wù))

  • 然后你打電話ExecutorService.shutdown(不允許更多的任務(wù)提交)和ExecutorService.awaitTermination(等到所有任務(wù)完成)

  • 最后,你調(diào)用Future.get所有的期貨來(lái)得到結(jié)果

    • 請(qǐng)注意,如果任務(wù)在執(zhí)行過(guò)程中拋出異常,則調(diào)用Future.get將拋出一個(gè)ExecutionException包裝任務(wù)拋出的異常


查看完整回答
反對(duì) 回復(fù) 2021-09-26
  • 1 回答
  • 0 關(guān)注
  • 871 瀏覽
慕課專欄
更多

添加回答

舉報(bào)

0/150
提交
取消
微信客服

購(gòu)課補(bǔ)貼
聯(lián)系客服咨詢優(yōu)惠詳情

幫助反饋 APP下載

慕課網(wǎng)APP
您的移動(dòng)學(xué)習(xí)伙伴

公眾號(hào)

掃描二維碼
關(guān)注慕課網(wǎng)微信公眾號(hào)