


How to use CompletableFuture to ensure the order of batch interface requests and efficiently process the results?
Apr 19, 2025 pm 09:09 PMJava concurrent programming: Use CompletableFuture to efficiently and orderly handle batch interface requests
High concurrent access to third-party interfaces can significantly improve data processing efficiency, but if the thread execution order is not controlled, the final result may not match the original data order, resulting in subsequent processing errors. This article introduces how to use Java's CompletableFuture to ensure the orderly processing of interface requests and results in a multi-threaded environment.
Problem: Use CompletableFuture.runAsync
directly to make asynchronous calls. Due to the unpredictable order of thread execution, the returned result is inconsistent with the order of the original data list. CompletableFuture.allOf
can only guarantee the completion of all tasks, and the order cannot be guaranteed.
Solution: Use CompletableFuture.supplyAsync
, which returns the result. Store the return result of each asynchronous task in CompletableFuture<string></string>
In the list, after all tasks are completed, the results are collected in the original order through stream().map(CompletableFuture::join).collect(Collectors.toList())
.
Improved code example:
public static void main(String[] args) { List<string> dataList = new ArrayList(); // Original data list// ... Initialize 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); // Call third-party interface to process data // ... Interface call and result processing logic... return data " - Processed Result"; // Return processing 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)); // Subsequent processing results}).thenRun(() -> executorService.shutdown()); }</string></completablefuture></string>
The improved code uses CompletableFuture.supplyAsync
to return the results of each interface call and is stored in the futures
list. CompletableFuture.allOf
ensures that the results are processed after all tasks are completed. stream().map(CompletableFuture::join).collect(Collectors.toList())
ensures that the results are collected in the original order, thus solving the problem of concurrency in the order of the results. The code also uses a custom thread pool for better control over resource usage.
The above is the detailed content of How to use CompletableFuture to ensure the order of batch interface requests and efficiently process the results?. For more information, please follow other related articles on the PHP Chinese website!

Hot AI Tools

Undress AI Tool
Undress images for free

Undresser.AI Undress
AI-powered app for creating realistic nude photos

AI Clothes Remover
Online AI tool for removing clothes from photos.

Clothoff.io
AI clothes remover

Video Face Swap
Swap faces in any video effortlessly with our completely free AI face swap tool!

Hot Article

Hot Tools

Notepad++7.3.1
Easy-to-use and free code editor

SublimeText3 Chinese version
Chinese version, very easy to use

Zend Studio 13.0.1
Powerful PHP integrated development environment

Dreamweaver CS6
Visual web development tools

SublimeText3 Mac version
God-level code editing software (SublimeText3)

Hot Topics

Against the backdrop of violent fluctuations in the cryptocurrency market, investors' demand for asset preservation is becoming increasingly prominent. This article aims to answer how to effectively hedge risks in the turbulent currency circle. It will introduce in detail the concept of stablecoin, a core hedge tool, and provide a list of TOP3 stablecoins by analyzing the current highly recognized options in the market. The article will explain how to select and use these stablecoins according to their own needs, so as to better manage risks in an uncertain market environment.

How do novice users choose a safe and reliable stablecoin platform? This article recommends the Top 10 stablecoin platforms in 2025, including Binance, OKX, Bybit, Gate.io, HTX, KuCoin, MEXC, Bitget, CoinEx and ProBit, and compares and analyzes them from dimensions such as security, stablecoin types, liquidity, user experience, fee structure and additional functions. The data comes from CoinGecko, DefiLlama and community evaluation. It is recommended that novices choose platforms that are highly compliant, easy to operate and support Chinese, such as KuCoin and CoinEx, and gradually build confidence through a small number of tests.

This article will discuss the world's mainstream stablecoins and analyze which stablecoins have the risk aversion attribute of "gold substitute" in the market downward cycle (bear market). We will explain how to judge and choose a relatively stable value storage tool in a bear market by comparing the market value, endorsement mechanism, transparency, and comprehensively combining common views on the Internet, and explain this analysis process.

As the market conditions pick up, more and more smart investors have begun to quietly increase their positions in the currency circle. Many people are wondering what makes them take decisively when most people wait and see? This article will analyze current trends through on-chain data to help readers understand the logic of smart funds, so as to better grasp the next round of potential wealth growth opportunities.

This article will introduce several mainstream stablecoins and explain in depth how to evaluate the security of a stablecoin from multiple dimensions such as transparency and compliance, so as to help you understand which stablecoins are generally considered relatively reliable choices in the market, and learn how to judge their "hazard-haven" attributes on your own.

Ethereum price has gone through several critical stages, from $0.70 in 2015 to $3,050 in 2025. 1) From 2015 to 2016, ETH rose from $0.70 to $20.64 in mid-2016; 2) from 2017 to 2018, driven by the ICO boom, reached $1,417 in early 2018, and then fell to $80 due to regulatory concerns; 3) from 2019 to 2020, and rose to $737 under DeFi; 4) from 2021, hit a new high of $4,864, and then fell to $1,200-2,000 due to PoS transformation; 5) from 2023 to 2024 to about $3,000

Recently, Bitcoin hit a new high, Dogecoin ushered in a strong rebound and the market was hot. Next, we will analyze the market drivers and technical aspects to determine whether Ethereum still has opportunities to follow the rise.

Stable coins are digital currencies that maintain stable value by anchoring specific assets. They are mainly divided into three categories: fiat currency collateral, crypto asset collateral and algorithmic. Among them, fiat currency collateral such as USDT and USDC are widely used, and their reserves are often invested in US Treasury bonds, forming a close connection with the traditional financial system.
