本文介绍一种线程安全、时间精确的方式，通过自定义 ThreadUnion 管理多线程生命周期，并实时收集每个完成线程的名称、结束时间及异常信息，避免 ConcurrentModificationException 和时间戳错乱问题。
本文介绍一种线程安全、时间精确的方式，通过自定义 `threadunion` 管理多线程生命周期，并实时收集每个完成线程的名称、结束时间及异常信息，避免 `concurrentmodificationexception` 和时间戳错乱问题。
在并发编程中，简单地用 Thread.start() 启动线程后，若需统一收集其执行结果（如完成时间、是否抛出异常），直接维护共享集合极易引发线程安全问题——正如提问中出现的 ConcurrentModificationException 和 finished 时间戳早于启动时刻等现象。根本原因在于：结果写入与遍历未同步、isAlive() 判定时机不准确、以及 LocalDateTime.now() 调用位置不当。
✅ 正确设计原则
- 结果仅在真正结束时记录：不能在 newThread() 中预创建 FinishedThreadResult，而应在 run() 正常退出或异常捕获后立即、原子地写入；
- 使用线程安全且不可变的数据结构：推荐 CopyOnWriteArrayList 存储结果（读多写少场景下性能优、无迭代并发异常）；
- 避免运行时检查 isAlive()：该方法仅反映「调用瞬间」状态，无法保证后续仍存活；应由线程自身负责“登记完成”；
- 时间戳必须在执行结束临界点获取：即 try 块末尾或 catch 异常处理块内调用 LocalDateTime.now()。
✅ 推荐实现（精简可运行版）
public class ThreadUnion {
private final String unionName;
private final AtomicInteger threadCounter = new AtomicInteger(0);
private final List<FinishedThreadResult> 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<FinishedThreadResult> results() {
// ✅ 返回不可修改副本，保障调用方安全
return Collections.unmodifiableList(new ArrayList<>(results));
}
}⚠️ 关键注意事项
- 禁止混用 UncaughtExceptionHandler 与手动 try-catch：二者会重复记录同一异常，且 UncaughtExceptionHandler 触发时机晚于 run() 结束，导致时间戳偏移；
- 不要在 results() 中动态计算状态（如 t.isAlive()）：这既低效又不可靠。应由线程自身“上报完成”，而非外部轮询；
- CopyOnWriteArrayList 是本方案核心：它允许并发读取（results() 频繁调用）与少量写入（线程结束时添加），完全规避 ConcurrentModificationException；
- 若需更高性能或更复杂生命周期控制（如超时、取消），应迁移至 ScheduledExecutorService + Future> 组合（如答案所建议），但本实现已满足题设接口契约与线程安全要求。
✅ 总结
可靠收集线程结果的关键，在于将「完成事件」建模为线程内主动上报行为，而非外部被动探测。通过封装 Runnable、统一异常处理路径、选用合适并发容器，即可在不引入额外框架的前提下，实现线程安全、时间精确、语义清晰的结果聚合机制。
