让自定义 Publisher 在 Swift Combine 上的不同 DispatchQueue 上运行

Question

我使用以下代码在 Swift Combine 中创建了一个返回自定义发布者的函数：

func customPubliher() -> AnyPublisher<Bool, Never> {
    return Future<Bool, Never> { promise in
        promise(.success(true))
    }.eraseToAnyPublisher()
}

然后我使用以下代码订阅了这个发布者：

customPublisher()
    .subscribe(on: DispatchQueue.global())
    .map { _ in
        print(Thread.isMainThread)
    }
    .sink(receiveCompletion: { _ in }, receiveValue: { value in
        // Do something with the value received
    }).store(in: &disposables)

但即使我在订阅时添加了.subscribe(on: DispatchQueue.global()) 行，代码不会在不同的队列中执行（.map 中的print 输出为真）。

但是，如果我将自定义发布者替换为内置的组合发布者之一，例如 Just()（见下文），则相同的代码将在不同的队列上正常执行：

Just(true)
    .subscribe(on: DispatchQueue.global())
    .map { _ in
        print(Thread.isMainThread)
    }
    .sink(receiveCompletion: { _ in }, receiveValue: { value in
        // Do something with the value received
    }).store(in: &disposables)

上面代码中的.map 输出错误。

我在使用自定义发布者时做错了什么？我希望它在不同的队列上运行，就像 Just() 发布者一样。

Answer 1

在我对您的代码的测试中，我得到了false。实际上DispatchQueue 与某个特定线程没有一对一的关系，它是一个执行队列并指定DispatchQueue.global() 你要求系统选择一些空闲队列 来执行你的任务默认优先级。因此，由系统决定在哪个队列和哪个线程中执行您的任务。

如果你故意想强制它进入后台，那么使用

.subscribe(on: DispatchQueue.global(qos: .background))