DispatchQueue.main 的 receive(on:) 行为

Question

从一个类中给出下面的代码：

cancellable = input
    .receive(on: scheduler)
    .map { ... }
    .sink(receiveValue: { value in
        self.state = value
    })

其中input 是 PassthroughSubject。

现在，当scheduler 是主队列或将从主线程调用 RunLoop.main AND 输入时，receive(on: scheduler) 是否会以编程方式优化对主队列的显式分派？

所以，基本上是这样的：

 if Thread.isMainThread { 
    /* execute closure */
 } else { 
    /* dispatch closure async to main */
 }

receive(on:) 的文档给出了一个模糊的提示，它可能会执行一些优化：

“首选接收（on：options :)而不是显式使用调度队列”

pub.sink {
    DispatchQueue.main.async {
        // Do something.
    }
}

Answer 1

不，receive(on:) 不会优化调度。这样做可能会导致僵局。示例：

let l = Lock()

let cancellable = input
    .receive(on: scheduler)
    .map { ... }
    .sink(receiveValue: { value in
        l.lock()
        self.state = value
        l.unlock()
    })

l.lock()
input.send(1)
l.unlock()

如果调度被消除，这个例子将尝试锁定已经锁定的锁l，然后挂起（如果它可以检测到死锁，则崩溃）。

Answer 2

查看RunLoop 和DispatchQueue 的源代码，看起来它们对Scheduler 协议的一致性没有这样的优化。

但公平地说，可能会有较低级别的优化在起作用。