使用CompletableFuture并行处理请求未生成全部Offer，求排查原因

核心问题1：请求列表传递错误 #

循环处理每个Location时，所有异步任务都传入了同一个locationRequestsList，而非当前Location对应的专属请求列表。直接导致：

• 所有线程重复处理同一批请求，不同Location的请求完全没被处理
• 最终生成的Offer只是同一批请求的重复结果，遗漏了其他Location的请求

修复：循环中传入当前Location对应的请求集合（假设location.getRequests()可获取该Location的请求）：

for (Location location : locations) {
    // 传入当前location对应的请求列表，而非全局的locationRequestsList
    CompletableFuture<List<Offer>> locationOffersFuture = processRequestsForLocation(location.getRequests());
    allLocationOffers.add(locationOffersFuture);
}

核心问题2：线程池滥用导致资源泄漏 #

processRequestsForLocation方法中，每次调用都会新建Executors.newCachedThreadPool()，造成：

• 大量无意义的线程池实例，每个线程池持有线程资源，最终引发线程泛滥
• CachedThreadPool的线程默认60秒才回收，频繁调用会触发OOM或性能骤降

修复：全局复用一个线程池，避免重复创建：

// 全局定义可复用的线程池（可根据业务调整核心线程数、最大线程数等参数）
private static final ExecutorService WORKER_POOL = Executors.newCachedThreadPool();

public static CompletableFuture<List<Offer>> processRequestsForLocation(List<Request> locationRequests) {
    return CompletableFuture.supplyAsync(() -> {
        List<Offer> offers = new ArrayList<>();
        for (Request request : locationRequests) {
            // create offer and add to offers
            offers.add(offer);
        }
        return offers;
    }, WORKER_POOL); // 复用全局线程池
}

// 程序结束时记得关闭线程池，避免资源泄漏
// WORKER_POOL.shutdown();

核心问题3：串行阻塞等待，丢失异步并行价值 #

用for循环逐个调用locationOffersFuture.get()，会导致前一个任务完成后才等待下一个任务，完全没利用CompletableFuture的并行能力，效率和同步处理无差异。

修复：用CompletableFuture.allOf()批量等待所有任务完成，再统一收集结果：

List<CompletableFuture<List<Offer>>> allLocationOffers = new ArrayList<>();
for (Location location : locations) {
    CompletableFuture<List<Offer>> locationOffersFuture = processRequestsForLocation(location.getRequests());
    allLocationOffers.add(locationOffersFuture);
}

// 批量等待所有异步任务完成
CompletableFuture<Void> allDone = CompletableFuture.allOf(
        allLocationOffers.toArray(new CompletableFuture[0])
);

List<Offer> allOffers = new ArrayList<>();
try {
    allDone.get(); // 等待所有任务完成
    // 统一收集所有结果
    for (CompletableFuture<List<Offer>> future : allLocationOffers) {
        allOffers.addAll(future.get());
    }
} catch (InterruptedException | ExecutionException e) {
    // 建议补充更严谨的异常处理，比如记录错误上下文、重试失败任务等
    e.printStackTrace();
}

核心问题4：异常处理不严谨 #

当前仅打印异常栈轨迹，某个任务失败时对应Offer会直接丢失，且上层无法感知错误。建议：

• 记录包含失败Location、请求信息的详细错误日志
• 针对失败任务添加重试逻辑
• 抛出上层可感知的异常，避免静默失败

内容的提问来源于stack exchange，提问作者user3628645