文章序列：

• Async/await
• Async Squences/Streams
• Task,Task group
• Actors

Task

在swift中创建Task很简单，使用Task类的构造函数就可以

let basicTask = Task {
    let result = await someAsync()
    return result
}

Task可以返回执行结果，当任务执行出错时也可以抛出异常

let basicTask = Task {
    // .. perform some work
    throw ExampleError.somethingIsWrong
}

do {
    print(try await basicTask.value)
} catch {
    print("Basic task failed with error: \(error)")
}

我们看一下Task的定义会发现创建Task实际上是通过构造一个闭包来初始化了一个Task实例，在这个闭包里可以执行任意异步函数。

public init(
    priority: _Concurrency.TaskPriority? = nil, 
    operation: @escaping  () async -> Success)

public init(
    priority: _Concurrency.TaskPriority? = nil, 
    operation: @escaping  () async throws -> Success)

除了 init 构造 Task 之外，Task 还提供 detach 函数来创建一个不一样的 Task：

public static func detached(
    priority: _Concurrency.TaskPriority? = nil, 
    operation: @escaping  () async -> Success
) -> _Concurrency.Task<Success, Failure>

public static func detached(
    priority: _Concurrency.TaskPriority? = nil, 
    operation: @escaping  () async throws -> Success
) -> _Concurrency.Task<Success, Failure>

Task.detached 创建的task和 Task.init 创建的Task有所不同的是 Task.detached 创建的task独立运行于当前的Actor，这个Actor的概念我们以后会讲到，你可以先简单理解为线程执行的隔离上下文（保障线程安全用的）。
Task的取消很简单，调用task的cancel方法就行

let imageTask = Task { () -> UIImage? in
        let imageURL = URL(string: "https://source.unsplash.com/random")!
        let (imageData, _) = try await URLSession.shared.data(from: imageURL)
        return UIImage(data: imageData)
    }
    // Cancel the image request right away:
    imageTask.cancel()

非结构化任务和结构化任务

通过Task创建构造的任务，也被称为非结构化的并发任务。与之对应的是添加到TaskGroup的任务被称为结构化Task。
TaskGroup可以通过add方法将一系列Task添加到一个组里面，TaskGroup会等待所有task都返回后才进行返回。

let images = await withTaskGroup(of: UIImage.self, returning: [UIImage].self) { taskGroup in
    let photoURLs = await listPhotoURLs(inGallery: "Amsterdam Holiday")
    for photoURL in photoURLs {
        taskGroup.addTask { await downloadPhoto(url: photoURL) }
    }

    var images = [UIImage]()
    for await result in taskGroup {
        images.append(result)
    }
    return images
}

TaskGroup 也遵循AsyncSequence协议，可以使用reduce方式获取结果

let images = try await withThrowingTaskGroup(of: UIImage.self, returning: [UIImage].self) { taskGroup in
    let photoURLs = try await listPhotoURLs(inGallery: "Amsterdam Holiday")
    for photoURL in photoURLs {
        taskGroup.addTask { try await downloadPhoto(url: photoURL) }
    }

    return try await taskGroup.reduce(into: [UIImage]()) { partialResult, image in
        partialResult.append(image)
    }
}

上述例子中的TaskGroup会等待每个任务都执行完成，如果遇到一个任务失败想要提前返回，也可以提前return或者针对ThrowingTaskGroup抛出异常

let images = try await withThrowingTaskGroup(of: UIImage.self, returning: [UIImage].self) { taskGroup in
    let photoURLs = try await listPhotoURLs(inGallery: "Amsterdam Holiday")
    for photoURL in photoURLs {
        taskGroup.addTask { try await downloadPhoto(url: photoURL) }
    }

    var images = [UIImage]()

    /// Note the use of `next()`:
    while let downloadImage = try await taskGroup.next() {
        images.append(downloadImage)
    }
    return images
}

这里调用next方法在结果返回为nil时结束了循环，提前return之前接收的结果集。

如果要对TaskGroup进行取消，可以调用cancelAll()对添加到组里的每个Task进行取消操作。需要注意的是TaskGroup调用取消操作后，后续添加的task不会自动开始而是自动取消，如果还需要任务进行可以通过addTaskUnlessCancelled()来让任务执行。