Java
javaTutorial
How to use CompletableFuture to ensure the order of batch interface requests and efficiently process the results?
How to use CompletableFuture to ensure the order of batch interface requests and efficiently process the results?
Apr 19, 2025 pm 09:09 PM
Java 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
The popularity of the currency circle has returned, why do smart people have begun to quietly increase their positions? Look at the trend from the on-chain data and grasp the next round of wealth password!
Jul 09, 2025 pm 08:30 PM
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.
What are the mainstream public chains of cryptocurrencies? The top ten rankings of cryptocurrency mainstream public chains in 2025
Jul 10, 2025 pm 08:21 PM
The pattern in the public chain field shows a trend of "one super, many strong ones, and a hundred flowers blooming". Ethereum is still leading with its ecological moat, while Solana, Avalanche and others are challenging performance. Meanwhile, Polkadot, Cosmos, which focuses on interoperability, and Chainlink, which is a critical infrastructure, form a future picture of multiple chains coexisting. For users and developers, choosing which platform is no longer a single choice, but requires a trade-off between performance, cost, security and ecological maturity based on specific needs.
Cardano's smart contract evolution: The impact of Alonzo upgrades on 2025
Jul 10, 2025 pm 07:36 PM
Cardano's Alonzo hard fork upgrade has successfully transformed Cardano from a value transfer network to a fully functional smart contract platform by introducing the Plutus smart contract platform. 1. Plutus is based on Haskell language, with powerful functionality, enhanced security and predictable cost model; 2. After the upgrade, dApps deployment is accelerated, the developer community is expanded, and the DeFi and NFT ecosystems are developing rapidly; 3. Looking ahead to 2025, the Cardano ecosystem will be more mature and diverse. Combined with the improvement of scalability in the Basho era, the enhancement of cross-chain interoperability, the evolution of decentralized governance in the Voltaire era, and the promotion of mainstream adoption by enterprise-level applications, Cardano has
Bitcoin breaks new highs, Dogecoin rebounds strongly, will Ethereum keep up with the pace
Jul 09, 2025 pm 08:24 PM
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.
The top 5 most worth investing in 2025 (with latest data)
Jul 09, 2025 am 06:06 AM
The five most valuable stablecoins in 2025 are Tether (USDT), USD Coin (USDC), Dai (DAI), First Digital USD (FDUSD) and TrueUSD (TUSD).
The flow of funds on the chain is exposed: What new tokens are being bet on by Clever Money?
Jul 16, 2025 am 10:15 AM
Ordinary investors can discover potential tokens by tracking "smart money", which are high-profit addresses, and paying attention to their trends can provide leading indicators. 1. Use tools such as Nansen and Arkham Intelligence to analyze the data on the chain to view the buying and holdings of smart money; 2. Use Dune Analytics to obtain community-created dashboards to monitor the flow of funds; 3. Follow platforms such as Lookonchain to obtain real-time intelligence. Recently, Cangming Money is planning to re-polize LRT track, DePIN project, modular ecosystem and RWA protocol. For example, a certain LRT protocol has obtained a large amount of early deposits, a certain DePIN project has been accumulated continuously, a certain game public chain has been supported by the industry treasury, and a certain RWA protocol has attracted institutions to enter.
Who issues stablecoins? What are the stablecoins?
Jul 09, 2025 pm 06:24 PM
Stablecoins are crypto assets that maintain price stability by anchoring fiat currencies such as the US dollar. They are mainly divided into three categories: fiat currency collateral, crypto asset collateral and algorithmic stablecoins. 1. USDT is issued by Tether and is the stablecoin with the largest market value and the highest liquidity. 2. USDC is released by the Centre alliance launched by Circle and Coinbase, and is known for its transparency and compliance. 3. DAI is generated by MakerDAO through over-collateralization of crypto assets and is the core currency in the DeFi field. 4. BUSD was launched in partnership with Paxos, and is regulated by the United States but has been discontinued. 5. TUSD achieves high transparency reserve verification through third-party escrow accounts. Users can use centralized exchanges such as Binance, Ouyi, and Huobi
Which chain does Dogecoin DOGE belong to? Does Dogecoin belong to the Binance Chain?
Jul 10, 2025 pm 08:39 PM
Recently, the discussion in the digital asset field has remained hot. Dogecoin DOGE, as one of the most popular focus, has become a question that many people have explored. Where does it "settling down"? What is the relationship with the current leading trading platform, Binance? To answer these questions, we need to conduct in-depth analysis from the two dimensions of the underlying technical logic of digital assets and the platform ecology, rather than just staying in appearance.
