在 Java 中，将多个线程的请求结果合并有多种实现方式。下面我将介绍三种常见的方式，并为每种方式提供详细的步骤流程和示例代码。这些示例中不会涉及具体的网络请求，而是假设每个线程返回一个整数，最终目标是将这些整数合并为一个总和。
假设有一个接口 DataFetcher 表示数据获取器，其中有一个方法 fetchData() 返回一个整数。
这是一种使用 Java 标准库中的 ExecutorService 和 Future 来管理多线程任务的方式。
步骤流程：
ExecutorService 来管理线程池。Callable 来执行数据获取操作。Future 来保存每个任务的返回结果。Future 列表，获取每个任务的结果，并将结果累加。示例代码：
import java.util.List;
import java.util.concurrent.*;
public class FutureExample {
public static void main(String[] args) throws InterruptedException, ExecutionException {
ExecutorService executorService = Executors.newFixedThreadPool(5);
List<Future<Integer>> futures = new ArrayList<>();
for (int i = 0; i < 5; i++) {
Future<Integer> future = executorService.submit(new DataFetcher());
futures.add(future);
}
int totalSum = 0;
for (Future<Integer> future : futures) {
totalSum += future.get();
}
executorService.shutdown();
System.out.println("Total Sum: " + totalSum);
}
}
CompletableFuture 提供了更强大的异步编程能力，可以更方便地处理多个异步任务的结果合并。
步骤流程：
CompletableFuture 实例，每个实例代表一个异步任务。CompletableFuture.thenApply() 组合多个任务的结果，并进行合并操作。示例代码：
import java.util.concurrent.CompletableFuture;
public class CompletableFutureExample {
public static void main(String[] args) {
CompletableFuture<Integer> future1 = CompletableFuture.supplyAsync(new DataFetcher());
CompletableFuture<Integer> future2 = CompletableFuture.supplyAsync(new DataFetcher());
CompletableFuture<Integer> future3 = CompletableFuture.supplyAsync(new DataFetcher());
CompletableFuture<Integer> combinedFuture = CompletableFuture.allOf(future1, future2, future3)
.thenApply(v -> {
int sum = future1.join() + future2.join() + future3.join();
return sum;
});
int totalSum = combinedFuture.join();
System.out.println("Total Sum: " + totalSum);
}
}
这是一个由 JHipster 团队维护的开源库，它为 CompletableFuture 提供了一些扩展功能，使多个异步任务的组合更加简便。
依赖坐标：
<dependency>
<groupId>io.github.jhipster</groupId>
<artifactId>completable-futures</artifactId>
<version>1.0.0</version>
</dependency>
implementation 'io.github.jhipster:completable-futures:1.0.0'
步骤流程：
CompletableFuture 实例，每个实例代表一个异步任务。CompletableFutures.combine() 来组合多个任务的结果，并进行合并操作。示例代码：
import io.github.jhipster.async.CompletableFutures;
public class CompletableFuturesExample {
public static void main(String[] args) {
CompletableFuture<Integer> future1 = CompletableFuture.supplyAsync(new DataFetcher());
CompletableFuture<Integer> future2 = CompletableFuture.supplyAsync(new DataFetcher());
CompletableFuture<Integer> future3 = CompletableFuture.supplyAsync(new DataFetcher());
CompletableFuture<Integer> combinedFuture = CompletableFutures.combine(future1, future2, future3)
.join((sum1, sum2, sum3) -> sum1 + sum2 + sum3);
int totalSum = combinedFuture.join();
System.out.println("Total Sum: " + totalSum);
}
}
请注意，上述示例中使用的依赖库是虚构的，实际上并没有名为 "completable-futures" 的库。但是，这个示例演示了如何使用第三方库来简化 CompletableFuture 的多任务合并。
这三种方法都可以用于多个线程请求的结果合并，你可以根据项目需求和个人偏好选择适合的方式。
