如何安全获取线程执行结果列表

本文介绍一种线程安全、时间精确的方式，通过自定义 ThreadUnion 管理多线程生命周期，并实时收集每个完成线程的名称、结束时间及异常信息，避免 ConcurrentModificationException 和时间戳错乱问题。

本文介绍一种线程安全、时间精确的方式，通过自定义 `ThreadUnion` 管理多线程生命周期，并实时收集每个完成线程的名称、结束时间及异常信息，避免 `ConcurrentModificationException` 和时间戳错乱问题。

在并发编程中，简单地用 Thread.start() 启动线程后，若需统一收集其执行结果（如完成时间、是否抛出异常），直接维护共享集合极易引发线程安全问题——正如提问中出现的 ConcurrentModificationException 和 finished 时间戳早于启动时刻等现象。根本原因在于：结果写入与遍历未同步、isAlive() 判定时机不准确、以及 LocalDateTime.now() 调用位置不当。

✅ 正确设计原则

1. 结果仅在真正结束时记录：不能在 newThread() 中预创建 FinishedThreadResult，而应在 run() 正常退出或异常捕获后立即、原子地写入；
2. 使用线程安全且不可变的数据结构：推荐 CopyOnWriteArrayList 存储结果（读多写少场景下性能优、无迭代并发异常）；
3. 避免运行时检查 isAlive()：该方法仅反映「调用瞬间」状态，无法保证后续仍存活；应由线程自身负责“登记完成”；
4. 时间戳必须在执行结束临界点获取：即 try 块末尾或 catch 异常处理块内调用 LocalDateTime.now()。

✅ 推荐实现（精简可运行版）

public class ThreadUnion {
    private final String unionName;
    private final AtomicInteger threadCounter = new AtomicInteger(0);
    private final List results = new CopyOnWriteArrayList<>();

    private ThreadUnion(String name) {
        this.unionName = name;
    }

    public static ThreadUnion newInstance(String name) {
        return new ThreadUnion(name);
    }

    public Thread newThread(Runnable task) {
        String threadName = String.format("%s-worker-%d", unionName, threadCounter.getAndIncrement());
        Thread t = new Thread(() -> {
            try {
                task.run();
                // ✅ 正常完成：立刻记录，时间精准
                results.add(new FinishedThreadResult(threadName));
            } catch (Throwable e) {
                // ✅ 异常完成：同样立即记录，含异常
                results.add(new FinishedThreadResult(threadName, e));
            }
        }, threadName);

        // ⚠️ 不再设置 UncaughtExceptionHandler！
        // 因为 run() 已包裹全部逻辑，所有异常均被显式捕获
        return t;
    }

    public List results() {
        // ✅ 返回不可修改副本，保障调用方安全
        return Collections.unmodifiableList(new ArrayList<>(results));
    }
}

⚠️ 关键注意事项

• 禁止混用 UncaughtExceptionHandler 与手动 try-catch：二者会重复记录同一异常，且 UncaughtExceptionHandler 触发时机晚于 run() 结束，导致时间戳偏移；
• 不要在 results() 中动态计算状态（如 t.isAlive()）：这既低效又不可靠。应由线程自身“上报完成”，而非外部轮询；
• CopyOnWriteArrayList 是本方案核心：它允许并发读取（results() 频繁调用）与少量写入（线程结束时添加），完全规避 ConcurrentModificationException；
• 若需更高性能或更复杂生命周期控制（如超时、取消），应迁移至 ScheduledExecutorService + Future 组合（如答案所建议），但本实现已满足题设接口契约与线程安全要求。

✅ 总结

可靠收集线程结果的关键，在于将「完成事件」建模为线程内主动上报行为，而非外部被动探测。通过封装 Runnable、统一异常处理路径、选用合适并发容器，即可在不引入额外框架的前提下，实现线程安全、时间精确、语义清晰的结果聚合机制。