多异步

在Java中，多个异步任务之间的协调可以通过一些方式来实现，下面介绍一些常用的方式。

1. CompletableFuture

CompletableFuture是Java 8中新增的一个类，用于处理多个异步任务之间的协调。它可以将多个异步任务组合成一个新的异步任务，可以等待所有异步任务完成后再进行下一步操作，也可以等待其中任意一个异步任务完成后就进行下一步操作。例如：

CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> {
    // 异步任务1
    return "result1";
});

CompletableFuture<String> future2 = CompletableFuture.supplyAsync(() -> {
    // 异步任务2
    return "result2";
});

CompletableFuture<String> future3 = future1.thenCombine(future2, (result1, result2) -> {
    // 异步任务3
    return result1 + result2;
});

// 等待异步任务3完成并获取结果
String result = future3.get();

这里使用`supplyAsync`方法创建两个异步任务，并使用`thenCombine`方法将它们组合成一个新的异步任务，在异步任务3中将异步任务1和异步任务2的结果进行合并。通过`get`方法等待异步任务3完成并获取结果。

2. CountDownLatch

CountDownLatch是Java中一个同步辅助类，可以在多个线程之间协调控制，例如等待所有线程执行完成后再进行下一步操作。使用时需要指定需要等待的线程数量，每个线程执行完成后调用`countDown`方法通知CountDownLatch计数器减1，当计数器为0时表示所有线程都执行完成。例如：

int threadCount = 10;
CountDownLatch latch = new CountDownLatch(threadCount);
for (int i = 0; i < threadCount; i++) {
    new Thread(() -> {
        // 异步任务
        latch.countDown();
    }).start();
}

// 等待所有线程执行完成
latch.await();

// 在此可以做其他事情

这里创建了10个线程来执行异步任务，并使用CountDownLatch等待所有线程执行完成后再进行下一步操作。

3. CompletionService

CompletionService是Java中一个异步处理的工具类，可以用于在多个异步任务中获取最先完成的异步任务的结果。例如：

ExecutorService executor = Executors.newFixedThreadPool(10);
CompletionService<String> completionService = new ExecutorCompletionService<>(executor);
for (int i = 0; i < 10; i++) {
    completionService.submit(() -> {
        // 异步任务
        return "result";
    });
}

// 等待最先完成的异步任务并获取结果
String result = completionService.take().get();

这里创建了10个异步任务，并使用CompletionService获取最先完成的异步任务的结果。可以使用`completionService.poll()`方法获取最先完成的异步任务的结果，如果没有任何异步任务完成则返回null。可以使用`completionService.take()`方法等待最先完成的异步任务并获取结果，该方法是一个阻塞方法，会一直等待直到有异步任务完成并返回结果。