高效并發(fā)處理批量接口請求：確保結(jié)果順序一致

高效率地處理大量數(shù)據(jù)時，并發(fā)調(diào)用多個第三方接口能顯著提升效率。然而，簡單的多線程并發(fā)可能導致返回結(jié)果順序錯亂，與原始數(shù)據(jù)列表對應(yīng)不上。本文將介紹如何利用Java的CompletableFuture解決這個問題，確保接口調(diào)用結(jié)果與原始數(shù)據(jù)順序完全一致。

問題：

假設(shè)需要并發(fā)調(diào)用1000多個第三方接口并處理返回結(jié)果。如果使用簡單的for循環(huán)啟動多個線程，接口調(diào)用的順序無法保證，最終結(jié)果的順序與原始數(shù)據(jù)列表不符。某些示例代碼使用CompletableFuture.runAsync執(zhí)行異步任務(wù)，但忽略了結(jié)果的收集和順序的維護。

解決方案：

為了保證結(jié)果順序與原始數(shù)據(jù)列表一致，關(guān)鍵在于使用CompletableFuture.supplyAsync代替CompletableFuture.runAsync。supplyAsync方法可以返回一個結(jié)果，而runAsync沒有返回值。通過supplyAsync返回每個接口調(diào)用的結(jié)果，再利用流式處理將結(jié)果收集到列表中，即可確保結(jié)果順序與原始數(shù)據(jù)列表一致。

改進后的代碼：

public static void main(String[] args) {
    List<string> dataList = new ArrayList(); // 原始數(shù)據(jù)列表
    // ... 初始化 dataList ...

    ExecutorService executorService = new ThreadPoolExecutor(
            //核心線程數(shù)
            Runtime.getRuntime().availableProcessors(),
            //最大線程數(shù)
            Runtime.getRuntime().availableProcessors() * 2,
            //線程存活時間
            60L, TimeUnit.SECONDS,
            new LinkedBlockingQueue(),
            new ThreadPoolExecutor.CallerRunsPolicy());

    List<completablefuture>> futures = new ArrayList();
    for (String data : dataList) {
        futures.add(CompletableFuture.supplyAsync(() -> {
            logger.info("開始執(zhí)行異步線程->>"   data);
            // 調(diào)用接口，傳入 data
            // 根據(jù)接口返回值判斷 data 是否匹配
            // 返回處理后的結(jié)果
            return processData(data); // 處理數(shù)據(jù)并返回結(jié)果
        }, executorService)); // 使用自定義線程池
    }

    // 所有請求完成后處理邏輯
    CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).thenRun(() -> {
        List<string> results = futures.stream()
                .map(CompletableFuture::join)
                .collect(Collectors.toList());
        logger.info("線程執(zhí)行完畢：{}", JSON.toJSONString(results));
        // 調(diào)用發(fā)送短信
    }).thenRun(() -> executorService.shutdown());
}

// 處理數(shù)據(jù)的方法，根據(jù)實際情況修改
private static String processData(String data) {
    // ...  接口調(diào)用和數(shù)據(jù)處理邏輯 ...
    return data   "處理后的結(jié)果";
}</string></completablefuture></string>

通過將每個CompletableFuture的結(jié)果存儲在futures列表中，并在最后使用futures.stream().map(CompletableFuture::join).collect(Collectors.toList())收集結(jié)果，就保證了結(jié)果順序與原始數(shù)據(jù)列表一致。CompletableFuture::join方法會阻塞直到獲取到CompletableFuture的結(jié)果。 這樣就有效解決了原代碼中結(jié)果順序錯亂的問題。

以上是如何利用CompletableFuture保證批量接口請求結(jié)果的順序一致性？的詳細內(nèi)容。更多資訊請關(guān)注PHP中文網(wǎng)其他相關(guān)文章！