如何利用CompletableFuture保证批量接口请求的顺序并高效处理结果？

Java并发编程：使用CompletableFuture高效有序处理批量接口请求

高并发访问第三方接口能显著提升数据处理效率，但如果不控制线程执行顺序，最终结果可能与原始数据顺序不符，导致后续处理错误。本文介绍如何利用Java的CompletableFuture在多线程环境下，确保接口请求及结果处理的有序性。

问题：直接使用CompletableFuture.runAsync进行异步调用，由于线程执行顺序不可预测，导致返回结果与原始数据列表顺序不一致。CompletableFuture.allOf仅能保证所有任务完成，无法保证顺序。

解决方案：使用CompletableFuture.supplyAsync，它能返回结果。将每个异步任务的返回结果存储在CompletableFuture列表中，所有任务完成后，通过stream().map(CompletableFuture::join).collect(Collectors.toList())按原始顺序收集结果。

改进后的代码示例：

public static void main(String[] args) {
    List<String> dataList = new ArrayList<>(); // 原始数据列表
    // ... 初始化dataList ...

    ExecutorService executorService = new ThreadPoolExecutor(
            10, // corePoolSize
            20, // maximumPoolSize
            60L, // keepAliveTime
            TimeUnit.SECONDS,
            new LinkedBlockingQueue<>(1024), // workQueue
            new ThreadPoolExecutor.CallerRunsPolicy() // handler
    );

    List<CompletableFuture<String>> futures = new ArrayList<>();
    for (String data : dataList) {
        futures.add(CompletableFuture.supplyAsync(() -> {
            logger.info("Processing data: {}", data);
            // 调用第三方接口，处理data
            // ...  接口调用及结果处理逻辑 ...
            return data + " - Processed Result"; // 返回处理结果
        }, 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));
        // 后续处理结果
    }).thenRun(() -> executorService.shutdown());
}

改进后的代码使用CompletableFuture.supplyAsync返回每个接口调用的结果，并存储在futures列表中。CompletableFuture.allOf确保所有任务完成后再处理结果，stream().map(CompletableFuture::join).collect(Collectors.toList())保证结果按原始顺序收集，从而解决了并发导致结果顺序错乱的问题。 代码还使用了自定义线程池，以便更好地控制资源使用。

以上就是如何利用CompletableFuture保证批量接口请求的顺序并高效处理结果？的详细内容，更多请关注知识资源分享宝库其它相关文章！