CountDownLatch的使用场景和代码实例

### CountDownLatch 结合 CompletableFuture 使用方法 在 Java 并发编程中，`CountDownLatch` 和 `CompletableFuture` 可以很好地结合起来处理复杂的并发场景。下面是一个具体的例子说明如何将两者结合使用。 #### 示例代码 假设有一个任务需要多个子任务完成后才能继续执行后续逻辑： ```java import java.util.concurrent.*; public class LatchAndFutureExample { public static void main(String[] args) throws InterruptedException { // 定义计数器初始值为3，表示有三个子任务 CountDownLatch latch = new CountDownLatch(3); // 创建一个带有自定义线程工厂的线程池 ExecutorService executor = Executors.newFixedThreadPool(3); // 存储所有的 completable futures var allFutures = new ArrayList<CompletableFuture<Void>>(); try { for (int i = 0; i < 3; ++i) { final int taskId = i; // 对于每一个子任务都创建一个新的 CompletableFuture 实例 CompletableFuture<Void> futureTask = CompletableFuture.runAsync(() -> { System.out.println("Executing task " + taskId); // 模拟耗时操作 try { Thread.sleep((long)(Math.random() * 1000)); } catch (InterruptedException e) {} // 当前子任务完成之后减少计数值 latch.countDown(); }, executor).thenRun(() -> { // 所有的 thenRun 都会在对应的 runAsync 完成后触发 System.out.println("Task " + taskId + " has finished."); }); // 添加到列表以便稍后统一处理结果 allFutures.add(futureTask); } // 主线程在此处等待直到所有子任务均已完成 latch.await(); // 统一处理各个 Future 的最终状态 CompletableFuture.allOf(allFutures.toArray(new CompletableFuture[0])).join(); System.out.println("All tasks have been completed."); } finally { executor.shutdown(); } } } ``` 此程序展示了如何利用 `CountDownLatch` 来同步一组并行运行的任务，并且通过 `CompletableFuture` 提供更强大的组合能力[^1]。 当涉及到更加复杂的应用场景时，比如某些情况下可能希望某个特定条件满足后再去启动其他依赖的操作，则可以考虑进一步探索 `CompletableFuture` 更多高级特性如 `completeOnTimeout`, `orTimeout` 等来增强灵活性和响应速度[^2]。