如何利用CompletableFuture保證批量接口請(qǐng)求的順序并高效處理結(jié)果？
Apr 19, 2025 pm 09:09 PM
Java并發(fā)編程：使用CompletableFuture高效有序處理批量接口請(qǐng)求
高并發(fā)訪問(wèn)第三方接口能顯著提升數(shù)據(jù)處理效率，但如果不控制線程執(zhí)行順序，最終結(jié)果可能與原始數(shù)據(jù)順序不符，導(dǎo)致后續(xù)處理錯(cuò)誤。本文介紹如何利用Java的CompletableFuture在多線程環(huán)境下，確保接口請(qǐng)求及結(jié)果處理的有序性。
問(wèn)題：直接使用CompletableFuture.runAsync進(jìn)行異步調(diào)用，由于線程執(zhí)行順序不可預(yù)測(cè)，導(dǎo)致返回結(jié)果與原始數(shù)據(jù)列表順序不一致。 CompletableFuture.allOf僅能保證所有任務(wù)完成，無(wú)法保證順序。
解決方案：使用CompletableFuture.supplyAsync ，它能返回結(jié)果。將每個(gè)異步任務(wù)的返回結(jié)果存儲(chǔ)在CompletableFuture<string></string>列表中，所有任務(wù)完成后，通過(guò)stream().map(CompletableFuture::join).collect(Collectors.toList())按原始順序收集結(jié)果。
改進(jìn)后的代碼示例：
public static void main(String[] args) {
List<string> dataList = new ArrayList(); // 原始數(shù)據(jù)列表// ... 初始化dataList ...
ExecutorService executorService = new ThreadPoolExecutor(
10, // corePoolSize
20, // maximumPoolSize
60L, // keepAliveTime
TimeUnit.SECONDS,
new LinkedBlockingQueue(1024), // workQueue
new ThreadPoolExecutor.CallerRunsPolicy() // handler
);
List <completablefuture> > futures = new ArrayList();
for (String data : dataList) {
futures.add(CompletableFuture.supplyAsync(() -> {
logger.info("Processing data: {}", data);
// 調(diào)用第三方接口，處理data
// ... 接口調(diào)用及結(jié)果處理邏輯...
return data " - Processed Result"; // 返回處理結(jié)果}, executorService));
}
CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).thenRun(() -> {
List<string> results = futures.stream()
.map(CompletableFuture::join)
.collect(Collectors.toList());
logger.info("All tasks completed. Results: {}", JSON.toJSONString(results));
// 后續(xù)處理結(jié)果}).thenRun(() -> executorService.shutdown());
}</string></completablefuture></string>
改進(jìn)后的代碼使用CompletableFuture.supplyAsync返回每個(gè)接口調(diào)用的結(jié)果，并存儲(chǔ)在futures列表中。 CompletableFuture.allOf確保所有任務(wù)完成后再處理結(jié)果， stream().map(CompletableFuture::join).collect(Collectors.toList())保證結(jié)果按原始順序收集，從而解決了并發(fā)導(dǎo)致結(jié)果順序錯(cuò)亂的問(wèn)題。 代碼還使用了自定義線程池，以便更好地控制資源使用。
以上是如何利用CompletableFuture保證批量接口請(qǐng)求的順序并高效處理結(jié)果？的詳細(xì)內(nèi)容。更多信息請(qǐng)關(guān)注PHP中文網(wǎng)其他相關(guān)文章！
熱AI工具
Undress AI Tool
免費(fèi)脫衣服圖片
Undresser.AI Undress
人工智能驅(qū)動(dòng)的應(yīng)用程序，用于創(chuàng)建逼真的裸體照片
AI Clothes Remover
用于從照片中去除衣服的在線人工智能工具。
Clothoff.io
AI脫衣機(jī)
Video Face Swap
使用我們完全免費(fèi)的人工智能換臉工具輕松在任何視頻中換臉！
熱門文章
熱工具
記事本++7.3.1
好用且免費(fèi)的代碼編輯器
SublimeText3漢化版
中文版，非常好用
禪工作室 13.0.1
功能強(qiáng)大的PHP集成開發(fā)環(huán)境
Dreamweaver CS6
視覺(jué)化網(wǎng)頁(yè)開發(fā)工具
SublimeText3 Mac版
神級(jí)代碼編輯軟件(SublimeText3)
Impossible Cloud Network(ICNT)是什么?怎么樣?幣安即將上線項(xiàng)目ICN全面介紹
Jul 07, 2025 pm 07:06 PM
目錄一、ICN是什么？二、ICNT最新動(dòng)態(tài)三、ICN與其他DePIN項(xiàng)目的對(duì)比及經(jīng)濟(jì)模型四、DePIN賽道的下一階段展望結(jié)語(yǔ)5月底，ICN（ImpossibleCloudNetwork）@ICN_Protocol宣布獲得NGPCapital戰(zhàn)略投資，估值達(dá)到4.7億美元，很多人第一反應(yīng)是：“小米投Web3了？”雖然這不是雷軍直接出手，但出手的，是曾押中小米、Helium、WorkFusion的那
2025年7月加密貨幣代幣高回報(bào)預(yù)期：炒作還是現(xiàn)實(shí)？
Jul 04, 2025 pm 08:42 PM
隨著2025年7月的臨近，加密市場(chǎng)正熱議哪些代幣可能帶來(lái)高回報(bào)。Pi、PEPE和FloppyPepe這些名字是否真的值得冒險(xiǎn)投資？2025年7月值得關(guān)注的潛力加密貨幣：虛火還是真金？進(jìn)入2025年中旬，關(guān)于高收益加密資產(chǎn)的討論熱度持續(xù)升溫。比特幣走勢(shì)與“山寨幣季節(jié)”預(yù)期引發(fā)投資者關(guān)注，像PiNetwork、PEPE和FloppyPepe這類代幣是否具備帶來(lái)可觀投資回報(bào)的潛力？我們來(lái)逐一分析其前景。山寨幣行情：七月能否如愿以償？在比特幣有望刷新歷史高位的背景下，“山寨幣季節(jié)”似乎正在醞釀。回
2025年穩(wěn)定幣投資新手教程 如何選擇安全的穩(wěn)定幣平臺(tái)
Jul 07, 2025 pm 09:09 PM
新手用戶如何選擇安全可靠的穩(wěn)定幣平臺(tái)？本文推薦了2025年Top 10穩(wěn)定幣平臺(tái)，包括Binance、OKX、Bybit、Gate.io、HTX、KuCoin、MEXC、Bitget、CoinEx和ProBit，并從安全性、穩(wěn)定幣種類、流動(dòng)性、用戶體驗(yàn)、手續(xù)費(fèi)結(jié)構(gòu)和額外功能等維度進(jìn)行對(duì)比分析。數(shù)據(jù)來(lái)源于CoinGecko、DefiLlama及社群評(píng)價(jià)，建議新手優(yōu)先選擇合規(guī)性強(qiáng)、操作簡(jiǎn)便、支持中文的平臺(tái)，如KuCoin與CoinEx，并通過(guò)少量測(cè)試逐步建立信心。
幣圈動(dòng)蕩如何避險(xiǎn)？TOP3穩(wěn)定幣榜單曝光
Jul 08, 2025 pm 07:27 PM
在加密貨幣市場(chǎng)劇烈波動(dòng)的背景下，投資者尋求資產(chǎn)保值的需求日益凸顯。本文旨在解答如何在動(dòng)蕩的幣圈中進(jìn)行有效避險(xiǎn)，將詳細(xì)介紹穩(wěn)定幣這一核心避險(xiǎn)工具的概念，并通過(guò)分析當(dāng)前市場(chǎng)公認(rèn)度較高的選項(xiàng)，提供一份TOP3穩(wěn)定幣榜單。文章會(huì)講解如何根據(jù)自身需求選擇和運(yùn)用這些穩(wěn)定幣，從而在不確定的市場(chǎng)環(huán)境中更好地管理風(fēng)險(xiǎn)。
全球穩(wěn)定幣市值PK！誰(shuí)才是熊市中的'黃金替代品
Jul 08, 2025 pm 07:24 PM
本文將圍繞全球主流穩(wěn)定幣展開探討，分析在市場(chǎng)下行周期（熊市）中，哪種穩(wěn)定幣更具備“黃金替代品”的避險(xiǎn)屬性。我們將通過(guò)對(duì)比各穩(wěn)定幣的市值、背書機(jī)制、透明度以及綜合網(wǎng)絡(luò)上的普遍看法，來(lái)闡述如何判斷和選擇一個(gè)在熊市中相對(duì)穩(wěn)健的價(jià)值儲(chǔ)存工具，并對(duì)這個(gè)分析過(guò)程進(jìn)行講解。
幣圈熱度回歸，為什么聰明人都開始悄悄加倉(cāng)？從鏈上數(shù)據(jù)看趨勢(shì)，把握下一輪財(cái)富密碼！
Jul 09, 2025 pm 08:30 PM
隨著市場(chǎng)行情的回暖，越來(lái)越多的聰明投資者開始在幣圈悄悄加倉(cāng)，不少人疑惑，是什么讓他們?cè)诖蠖鄶?shù)人觀望時(shí)果斷出手？本文將通過(guò)鏈上數(shù)據(jù)分析當(dāng)前趨勢(shì)，幫助讀者理解聰明資金的邏輯，從而更好地把握下一輪潛在的財(cái)富增長(zhǎng)機(jī)會(huì)。
Remittix、門羅幣與加密貨幣-法幣的演變：為何引發(fā)熱議？
Jul 04, 2025 pm 09:33 PM
探索Remittix(RTX)、門羅幣(XMR)與加密-法幣趨勢(shì)：這些項(xiàng)目如何通過(guò)實(shí)用性和社區(qū)導(dǎo)向塑造加密貨幣的未來(lái)。Remittix、門羅幣與加密-法幣演進(jìn)：到底在熱炒什么？加密市場(chǎng)始終處于動(dòng)態(tài)變化之中，新舊項(xiàng)目都在爭(zhēng)奪投資者目光。目前，Remittix（RTX）、門羅幣（XMR）以及加密-法幣方向正成為討論焦點(diǎn)。我們來(lái)一探究竟，這波熱度背后有哪些驅(qū)動(dòng)力？Remittix：潛力初現(xiàn)的新興代幣Remittix正逐步贏得市場(chǎng)關(guān)注，其發(fā)展軌跡被部分人士類比為比特幣和以太坊早期階段。“CryptoR
埃隆·馬斯克、薩姆·奧爾特曼與Robinhood：一場(chǎng)代幣化的拉鋸戰(zhàn)？
Jul 04, 2025 pm 08:30 PM
Robinhood推出的OpenAI和SpaceX代幣化股票引發(fā)爭(zhēng)議，埃隆·馬斯克（ElonMusk）與薩姆·阿爾特曼（SamAltman）就所謂“假股權(quán)”的性質(zhì)展開互懟。近期，埃隆·馬斯克、薩姆·阿爾特曼與Robinhood的交集成為公眾關(guān)注焦點(diǎn)，這一切都源于代幣化股權(quán)。Robinhood向歐洲用戶推出OpenAI和SpaceX等私營(yíng)公司的代幣化股票，引發(fā)了激烈爭(zhēng)論，并伴隨著各方的澄清與批評(píng)。Robinhood的代幣化股權(quán)：大膽嘗試？由CEO弗拉德·特內(nèi)夫（VladTenev）主導(dǎo)的Robin
