Swift中的任务队列：GCD、OperationQueue和Combine用于iOS/macOS

Swift（iOS/macOS）任务队列：完整指南

在iOS和macOS开发中，高效管理线程和任务队列是创建响应迅速且高性能应用程序的关键。Swift提供了多种强大的异步处理工具：从经典的Grand Central Dispatch（GCD）到现代的async/await模型和Combine框架。本文将介绍主要方法、它们的特点以及使用示例。

1. Grand Central Dispatch（GCD）——多线程的基础

GCD是Apple用于管理代码并行执行的低级库。核心元素是DispatchQueue，它可以是串行（serial）或并发（concurrent）的。

主要队列：

• main —— 主队列（UI线程）。所有界面更新必须在此队列上执行。
• global —— 具有不同优先级（background、utility、default、userInitiated、userInteractive）的系统并发队列。
• custom —— 通过DispatchQueue(label:attributes:)创建的自定义队列。

示例：后台加载图片

import UIKit

class ImageLoader {    func loadImage(from url: URL, completion: @escaping (UIImage?) -> Void) {        DispatchQueue.global(qos: .background).async {            guard let data = try? Data(contentsOf: url),                  let image = UIImage(data: data) else {                DispatchQueue.main.async {                    completion(nil)                }                return            }            DispatchQueue.main.async {                completion(image)            }        }    }}

2. OperationQueue——灵活的任务管理

OperationQueue是比GCD更高级的抽象。它允许创建操作之间的依赖关系、设置最大并发任务数以及取消操作。

关键功能：

• 创建BlockOperation或自定义的Operation子类。
• 设置依赖关系：operation2.addDependency(operation1)。
• 取消所有操作：queue.cancelAllOperations()。
• 服务质量（quality of service）控制。

示例：顺序下载文件

import Foundation

let queue = OperationQueue()queue.maxConcurrentOperationCount = 1 // 顺序执行

let fetchMetadata = BlockOperation {    print("正在下载元数据...")    Thread.sleep(forTimeInterval: 1)}

let downloadContent = BlockOperation {    print("正在下载内容...")    Thread.sleep(forTimeInterval: 2)}

downloadContent.addDependency(fetchMetadata)

queue.addOperations([fetchMetadata, downloadContent], waitUntilFinished: false)print("操作已加入队列")

3. Swift Concurrency（async/await）——现代方法

从Swift 5.5开始，Apple引入了内置的异步模型，使用关键字async和await。它允许以线性方式编写异步代码，无需闭包和回调。

主要组件：

• async —— 标记异步函数。
• await —— 等待异步操作的结果。
• Task —— 创建异步上下文。
• TaskGroup —— 分组并行任务。

示例：并行下载数据

import Foundation

func fetchUser(id: Int) async -> String {    // 模拟网络请求    try? await Task.sleep(nanoseconds: 1_000_000_000)    return "User_\\(id)"}

func loadAllUsers() async {    await withTaskGroup(of: String