Java中等待动态创建的多线程完成的问题求助

这个场景我之前做测试框架时碰到过，线程层层创建确实容易在等待逻辑上踩坑，咱们先拆解下你当前代码的问题，再给你两个简单的解决方案～

为什么现有方案会出问题？ #

1. 普通ArrayList导致死锁/异常：ArrayList本身不是线程安全的，当Thread A遍历它的同时，其他线程可能在往列表里新增线程，这会触发ConcurrentModificationException，甚至因为并发修改导致迭代器逻辑混乱，最终死锁。
2. CopyOnWriteArrayList提前退出循环：CopyOnWriteArrayList的迭代器是创建时的快照——也就是说，当Thread A开始遍历的时候，迭代器只会包含那一刻列表里的线程，之后动态新增的线程根本不会被迭代器看到。所以第一批线程跑完后，迭代器就遍历结束了，Thread A直接退出，完全没等后续创建的线程。

简单解决方案 #

方案一：用AtomicInteger做线程计数器（代码改动最小） #

不需要维护线程列表，用一个线程安全的计数器跟踪所有活跃线程即可：

// 定义线程安全的计数器，初始值为0
private final AtomicInteger activeThreads = new AtomicInteger(0);

// 每个新线程启动前，先将计数器+1
activeThreads.incrementAndGet();

// 在每个线程的run方法最后，务必将计数器-1（放在finally块避免异常导致计数错误）
@Override
public void run() {
    try {
        // 你的线程业务逻辑
    } finally {
        activeThreads.decrementAndGet();
    }
}

// Thread A的等待逻辑
while (activeThreads.get() > 0) {
    try {
        // 适当延长sleep时间，减少空转浪费CPU
        TimeUnit.MILLISECONDS.sleep(10);
    } catch (InterruptedException e) {
        // 恢复中断状态，避免后续逻辑忽略中断信号
        Thread.currentThread().interrupt();
        // 可根据业务需求决定是否终止等待
        break;
    }
}

核心逻辑：不管线程怎么嵌套创建，只要每个线程启动时加计数、结束时减计数，Thread A只需等待计数器归0，完全不用管线程列表的动态变化。

方案二：用Phaser做动态线程同步（更优雅） #

JDK7+提供的Phaser专门用于处理动态增减参与者的同步场景，比计数器更省心：

// 初始化Phaser，初始参与者数为1（代表Thread A自己）
private final Phaser phaser = new Phaser(1);

// 每个新线程启动前，注册为Phaser的参与者
phaser.register();

// 线程run方法最后，告知Phaser自己已完成
@Override
public void run() {
    try {
        // 你的线程业务逻辑
    } finally {
        phaser.arriveAndDeregister();
    }
}

// Thread A的等待逻辑：等待所有注册的参与者完成
phaser.arriveAndAwaitAdvance();

Phaser会自动跟踪所有注册的线程，当所有线程都调用arriveAndDeregister()后，Thread A的arriveAndAwaitAdvance()就会返回，无需手动管理计数。

小提示 #

• 不管用哪种方案，都要把计数/Phaser操作放在finally块里，避免线程因异常退出导致计数无法归0、或Phaser一直等待。
• 不要用while(t.isRunning())轮询单个线程的方式，既浪费CPU，又无法处理动态新增的线程。

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