遍历数组时如何安全移除元素？闭包数组的安全执行与移除方案

嘿，这个问题戳中了多线程/异步场景下的经典竞态坑——直接用forEach遍历再加removeAll的操作完全不是原子的，中间插进来的新闭包要么被误删没执行，要么留在数组里但你以为已经清完了，确实得换更安全的思路。而且完全可以不用显式线程锁，靠算法和原子操作实现安全处理，下面给你两种靠谱的方案：

1. 原子替换数组（最简单的无锁实现） #

核心思路是先把当前数组的所有元素原子性地取出来，同时把原数组替换为空，之后再执行取出来的闭包。这样新加入的闭包会直接进入空数组，不会混入当前要执行的批次，也不会被误删。

举个Swift的例子（其他语言类似，只要保证数组替换是原子操作）：

// 用原子类型存储闭包数组（Swift 5.10+标准库支持Atomic）
let closures = Atomic<[() -> Void]>([])

func processAndClearClosures() {
    // 原子性地取出当前所有闭包，并将原数组设为空
    let currentBatch = closures.swap([])
    // 执行取出的所有闭包
    currentBatch.forEach { $0() }
}

为什么安全？ #

• swap操作是原子的：在多线程环境下，不会出现“取数组一半的时候，另一个线程加了新元素”的情况，要么取到完整的旧数组，要么取到空（但这种情况只会发生在另一个线程刚执行完swap）。
• 新加入的闭包会被存在新的空数组里，等下一次调用processAndClearClosures时再处理，不会被遗漏或误删。

2. 无锁队列（高并发场景更优） #

如果你的场景是频繁添加闭包、高并发访问，用无锁队列（基于CAS操作实现）会比原子数组更高效，因为队列的入队/出队都是原子操作，不需要每次替换整个数组。

伪代码逻辑（不同语言的无锁队列实现细节不同，但核心流程一致）：

// 假设已经有一个实现好的无锁队列LockFreeQueue
let closureQueue = LockFreeQueue<() -> Void>()

func processAndClearQueue() {
    var batch = []
    // 原子出队所有元素，直到队列为空
    while let closure = closureQueue.dequeue() {
        batch.append(closure)
    }
    // 批量执行闭包
    batch.forEach { $0() }
}

为什么安全？ #

• 无锁队列的dequeue操作是基于CAS（比较并交换）实现的原子操作，每次出队只会拿到当前队列头部的元素，不会和其他线程的入队/出队操作冲突。
• 新加入的闭包会被加到队列尾部，不会被当前的出队循环取到，保证当前批次只处理调用processAndClearQueue时已存在的闭包。

注意事项 #

• 闭包执行时间过长的问题：如果某个闭包执行耗时很久，新加入的闭包会暂时积累在数组/队列里，等当前批次执行完后，下次处理时再执行——这是合理的，因为我们要保证的是“安全处理当前存在的元素”，而不是实时处理（如果要实时处理，那本来就不该批量清空）。
• 原子操作的语言支持：不同语言对原子操作的支持不同，比如Java可以用AtomicReference，Go可以用sync/atomic包，Swift现在有标准库的Atomic类型，要确保你用的原子操作是线程安全的。

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