Swift 并发中的任务让步(Yielding)和防抖(Debouncing)

发布于:2025-03-19 ⋅ 阅读:(17) ⋅ 点赞:(0)

在这里插入图片描述

网罗开发 (小红书、快手、视频号同名)

  大家好,我是 展菲,目前在上市企业从事人工智能项目研发管理工作,平时热衷于分享各种编程领域的软硬技能知识以及前沿技术,包括iOS、前端、Harmony OS、Java、Python等方向。在移动端开发、鸿蒙开发、物联网、嵌入式、云原生、开源等领域有深厚造诣。

图书作者:《ESP32-C3 物联网工程开发实战》
图书作者:《SwiftUI 入门,进阶与实战》
超级个体:COC上海社区主理人
特约讲师:大学讲师,谷歌亚马逊分享嘉宾
科技博主:华为HDE/HDG

我的博客内容涵盖广泛,主要分享技术教程、Bug解决方案、开发工具使用、前沿科技资讯、产品评测与使用体验。我特别关注云服务产品评测、AI 产品对比、开发板性能测试以及技术报告,同时也会提供产品优缺点分析、横向对比,并分享技术沙龙与行业大会的参会体验。我的目标是为读者提供有深度、有实用价值的技术洞察与分析。

展菲:您的前沿技术领航员
👋 大家好,我是展菲!
📱 全网搜索“展菲”,即可纵览我在各大平台的知识足迹。
📣 公众号“Swift社区”,每周定时推送干货满满的技术长文,从新兴框架的剖析到运维实战的复盘,助您技术进阶之路畅通无阻。
💬 微信端添加好友“fzhanfei”,与我直接交流,不管是项目瓶颈的求助,还是行业趋势的探讨,随时畅所欲言。
📅 最新动态:2025 年 3 月 17 日
快来加入技术社区,一起挖掘技术的无限潜能,携手迈向数字化新征程!

前言

本篇文章的主题是 任务让步(Task Yielding)防抖(Debouncing)。Swift 并发为我们提供了两个简单但非常强大的函数:yieldsleep。今天我们就来看看它们的用法,以及在什么场景下应该使用它们。

什么是任务防抖(Debouncing)?

想象一下,你正在开发一个搜索功能,用户每输入一个字符,程序就会去一个庞大的数据集里查找匹配的结果。如果不加控制,每次键入都会触发新的搜索任务,可能会导致多个任务同时执行,影响性能甚至引发竞争条件(Race Condition)。

比如,下面这个 SwiftUI 代码:

@MainActor @Observable final class Store {
    private(set) var results: [HKCorrelation] = []
    private let store = HKHealthStore()

    func search(matching query: String) async {
        // 执行复杂的搜索任务
    }
}

struct ContentView: View {
    @State private var store = Store()
    @State private var query = ""

    var body: some View {
        NavigationStack {
            List(store.results, id: \.uuid) { result in
                Text(verbatim: result.endDate.formatted())
            }
            .searchable(text: $query)
            .task(id: query) {
                await store.search(matching: query)
            }
        }
    }
}

在这个代码里,每次用户输入新字符,都会创建一个新的任务去执行搜索。而 Swift 并发采用 协作式取消机制(Cooperative Cancellation),也就是说,它不会直接强行终止任务,而是提供一个“取消标记”,任务需要自己检查并响应取消请求。因此,这种写法可能会导致多个搜索任务并行运行,消耗不必要的计算资源。

为了解决这个问题,我们可以用 防抖(Debouncing) 技术。

如何用 sleep 实现防抖?

防抖的思路很简单:

  • 用户输入时,我们 等待一小段时间,看看用户是否继续输入。
  • 如果输入仍然在变化,我们就 继续等待,而不是立即启动搜索。
  • 只有当输入 稳定 一定时间后,才触发搜索任务。

换句话说,如果用户输入 "apple",我们希望忽略 "a", "ap", "app", "appl",只在最终输入 "apple" 后再进行搜索。

在 Swift 并发中,我们可以用 Task.sleep 来实现这个效果:

struct ContentView: View {
    @State private var store = Store()
    @State private var query = ""

    var body: some View {
        NavigationStack {
            List(store.results, id: \.uuid) { result in
                Text(verbatim: result.endDate.formatted())
            }
            .searchable(text: $query)
            .task(id: query) {
                do {
                    try await Task.sleep(for: .seconds(1))  // 等待 1 秒
                    await store.search(matching: query)  // 执行搜索
                } catch {
                    // 任务可能因为新输入被取消
                }
            }
        }
    }
}

为什么这样就能实现防抖?

  • Task.sleep(for: .seconds(1)) 让当前任务暂停 1 秒。
  • 如果用户在 1 秒内继续输入,之前的任务会被取消,新任务重新计时。
  • 只有 用户停止输入超过 1 秒,才会触发真正的搜索任务。

效果: 这样可以避免在输入过程中反复触发搜索,减少不必要的计算量。

什么是任务让步(Task Yielding)?

除了防抖,Swift 并发还提供了 任务让步(Task Yielding),让你在执行长时间任务时,主动把线程让出来,让其他任务有机会运行。

想象一个场景:

你需要解析一批巨大的 JSON 文件,并将数据保存到磁盘。这个过程可能会运行很久,占用线程资源。如果你在主线程或并发线程池(Cooperative Thread Pool)上运行这种任务,会 阻塞其他任务的执行,导致性能问题。

比如,下面是一个解析 JSON 文件的代码:

struct Item: Decodable {
    // 解析 JSON 的结构
}

struct DataHandler {
    func process(json files: [Data]) async throws -> [Item] {
        let decoder = JSONDecoder()
        var result: [Item] = []

        for file in files {
            let items = try decoder.decode([Item].self, from: file)
            result.append(contentsOf: items)
        }

        return result
    }
}

这个 process 函数会遍历所有 JSON 文件,并解析它们。但问题是:

  • 解析 JSON 是一个 同步操作,它不会自动释放 CPU 资源。
  • 如果 JSON 文件很大,整个解析过程可能会 占用线程很长时间,导致其他任务被阻塞。

如何用 yield 让出线程?

为了解决这个问题,我们可以 在每次解析完一个 JSON 文件后,让出线程,让其他任务有机会执行:

struct DataHandler {
    func process(json files: [Data]) async throws -> [Item] {
        let decoder = JSONDecoder()
        var result: [Item] = []

        for file in files {
            let items = try decoder.decode([Item].self, from: file)
            result.append(contentsOf: items)

            await Task.yield()  // 让出线程,让其他任务有机会执行
        }

        return result
    }
}

任务让步的好处:

  • await Task.yield() 会让当前任务 暂停一下,让其他等待中的任务有机会执行。
  • 之后,系统会恢复这个任务的执行,继续处理下一个 JSON 文件。
  • 这样可以 更公平地分配 CPU 资源,防止某个任务独占线程。

什么时候需要 yield?

通常来说,如果你的代码已经是 异步的(async/await),系统会自动在 await 语句处让出线程。所以 大部分情况下,你不需要手动 yield

但是,当你处理 非异步 API(比如 JSON 解析、图片处理、大量计算等)时,手动 yield 可能会提升性能。

总结

  1. 防抖(Debouncing)

    • 适用于 用户频繁输入的场景,如搜索框、按钮点击等。
    • 通过 Task.sleep(for:) 实现,等输入稳定后再执行任务。
    • 避免频繁创建任务,提高性能。
  2. 任务让步(Task Yielding)

    • 适用于 长时间运行的计算密集型任务,如解析 JSON、图片处理等。
    • 通过 Task.yield() 让出 CPU,避免线程被长时间占用。
    • 让其他任务有机会执行,提高系统响应速度。

这两个技巧虽然简单,但在实际开发中非常有用,可以帮助你更高效地利用 Swift 并发,让你的应用运行得更流畅!