Swift Combine的.collect操作符发射线程及崩溃问题咨询

核心结论 #

.collect操作符本身不会主动切换线程，它发射收集结果的线程，完全由上游发布者发送finished信号时所在的线程决定。

代码崩溃原因分析 #

你的代码中：

1. 第一个handleEvents校验通过，说明MergeMany的所有子发布者的output值都是在主线程发射的。
2. 但.collect需要等待上游（即MergeMany）发送finished信号后，才会一次性输出收集到的所有值。如果最后一个子发布者的finished信号是在后台线程发送的，那么MergeMany就会在该后台线程转发finished信号，此时.collect会直接在这个后台线程发射收集结果，触发第二个主线程前置条件校验崩溃。

简单来说：子发布者的业务值在主线程发射，但它的完成信号可能跑在后台，这就导致.collect的输出线程偏离主线程。

解决方案 #

如果要求.collect的输出必须在主线程，只需显式添加.receive(on: DispatchQueue.main)调度器，强制下游在主线程接收值：

return Publishers.MergeMany(publishers)
    .handleEvents(receiveOutput: { _ in
        precondition(Thread.isMainThread) // 正常
    })
    .collect()
    .receive(on: DispatchQueue.main) // 强制切换到主线程
    .handleEvents(receiveOutput: { _ in
        precondition(Thread.isMainThread) // 不再崩溃
    })

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