Swift Academy · 课时

调度器与线程

Q: 「调度器与线程」这节课中我会学到什么？

使用 receive(on:) 和 subscribe(on:) 控制执行。 你通过在浏览器中直接运行的动手代码来练习 Swift Academy，全天候 AI 导师会在你学习这节课的过程中回答你的问题。

使用 receive(on:) 和 subscribe(on:) 控制执行。

调度器与线程 是 CoddyKit 上的免费 Swift Academy 课时。这是第 2 节课，共 4 节。你可以在下方免费阅读本课时的完整内容 — 然后在浏览器中使用内置代码编辑器和全天候 AI 导师进行实践。这是 Swift Academy 学习路径的一部分，你的进度在网页和 CoddyKit 应用中同步。 Swift Academy 课程共包含 4 节课。

组合框架中的调度器

组合框架中的调度器定义了工作何时以及在哪里运行——也就是由哪个线程或队列执行运算符并向订阅者传递值。

控制调度器对于让用户界面更新在主线程上执行，并将繁重工作移出主线程至关重要。

两个关键运算符

组合框架提供了两个用于控制线程的运算符：

subscribe(on:)——控制订阅以及上游工作从哪里开始
receive(on:)——控制下游值在哪里传递

它们影响流水线的不同端。

receive(on:)

receive(on:) 会将它之后的所有工作转移到指定的调度器上。最常见的用途是在更新用户界面之前切回主队列。

apiClient.fetchUser(id: 1)
    .receive(on: DispatchQueue.main)
    .sink { user in
        self.nameLabel.text = user.name
    }
    .store(in: &cancellables)

subscribe(on:)

subscribe(on:) 控制 publisher 开始产生值以及上游运算符运行的线程。使用它可以将开销较大的初始化工作移出主线程。

heavyPublisher
    .subscribe(on: DispatchQueue.global(qos: .userInitiated))
    .receive(on: DispatchQueue.main)
    .sink { result in
        self.update(result)
    }
    .store(in: &cancellables)

subscribe(on:) 与 receive(on:)

请记住它们的方向：

subscribe(on:) 影响上游——工作从哪里开始
receive(on:) 影响下游——结果在哪里传递

典型模式是使用 subscribe(on:) 执行 background 工作，并使用 receive(on:) 将结果传递到主线程。

将 DispatchQueue 作为调度器

DispatchQueue 遵循 Scheduler 协议。DispatchQueue.main 会在主线程上传递值；global 队列则在 background 中并发运行。

let background = DispatchQueue.global(qos: .background)

publisher
    .map { expensiveTransform($0) }
    .subscribe(on: background)
    .receive(on: DispatchQueue.main)
    .sink { self.render($0) }
    .store(in: &cancellables)

将 RunLoop 作为调度器

RunLoop 是另一种调度器，与线程的运行循环绑定。RunLoop.main 会配合用户界面事件传递值，这对于滚动流畅度等场景可能很重要。

timerPublisher
    .receive(on: RunLoop.main)
    .sink { _ in
        self.tick()
    }
    .store(in: &cancellables)

DispatchQueue 与 RunLoop

两者都可以在主线程上传递值，但存在一些细微差异：

DispatchQueue.main——即使在滚动跟踪期间也会安排工作
RunLoop.main——在运行循环处于跟踪模式时会推迟工作

对于异步工作完成后的大多数用户界面更新，DispatchQueue.main 是更安全的默认选择。

调度器计时运算符

debounce、节流和延迟等运算符都会接收一个调度器参数，用来决定由哪个队列处理它们的计时。

searchTextPublisher
    .debounce(for: .milliseconds(300), scheduler: DispatchQueue.main)
    .sink { query in
        self.runSearch(query)
    }
    .store(in: &cancellables)

常见的线程错误

在主线程之外更新用户界面会导致崩溃或异常。如果在 background publisher 之后忘记使用 receive(on: DispatchQueue.main)，您的 sink 可能会在 background 线程上运行。

请始终在主调度器上传递面向用户界面的值。

整合起来

健壮的流水线会在 background 中开始工作，在那里完成处理，然后将结果传递到主线程进行显示。

imageURLPublisher
    .subscribe(on: DispatchQueue.global())
    .flatMap { url in downloadImage(url) }
    .map { resize($0) }
    .receive(on: DispatchQueue.main)
    .sink { self.imageView.image = $0 }
    .store(in: &cancellables)

快速检查

测试您对调度器的理解。

回顾

您学习了如何在组合框架中控制线程：

subscribe(on:)——上游工作从哪里开始
receive(on:)——结果在哪里传递
将 DispatchQueue 和 RunLoop 用作调度器
始终在主线程上传递用户界面更新

正确的调度可以让应用保持响应并避免崩溃。

常见问题解答

「调度器与线程」课时是免费的吗？

是的 — 「调度器与线程」的完整文本可在网页上免费阅读。要进行交互式练习（内置代码编辑器和全天候 AI 导师）并解锁 Swift Academy 课程的其余内容，请升级到 CoddyKit PRO。 Swift Academy 课程共包含 4 节课。

「调度器与线程」这节课中我会学到什么？

使用 receive(on:) 和 subscribe(on:) 控制执行。你通过在浏览器中直接运行的动手代码来练习 Swift Academy，全天候 AI 导师会在你学习这节课的过程中回答你的问题。

学习 Swift Academy 需要有经验吗？

无需任何先前经验。CoddyKit 上的 Swift Academy 课程适合初学者到高级学习者，你可以从这里开始或从头开始，按照自己的节奏学习。这是第 2 节课，共 4 节。

「调度器与线程」课时需要多长时间？

大多数 CoddyKit 课程大约需要 5–10 分钟。每节课都很精短且互动，所以你能稳步进步，并在网页和应用中从离开的地方继续。

我能在这节 Swift Academy 课中编写并运行代码吗？

能。每节 Swift Academy 课都包含内置代码编辑器，你可以在浏览器中直接编写并运行真实代码，并获得即时 AI 反馈 — 无需本地设置。

此课程中的所有课时

← 返回 Swift Academy