草庐IT

Swift 中的 Async/Await ——代码实例详解

Swift君 2023-03-28 原文

​前言

async-await 是在 WWDC 2021 期间的 Swift 5.5 中的结构化并发变化的一部分。Swift 中的并发性意味着允许多段代码同时运行。这是一个非常简化的描述,但它应该让你知道 Swift 中的并发性对你的应用程序的性能是多么重要。有了新的 async 方法和 await 语句,我们可以定义方法来进行异步工作。

你可能读过 Chris Lattner 的 Swift 并发性宣言 Swift Concurrency Manifesto by Chris Lattner[1],这是在几年前发布的。Swift社区的许多开发者对未来将出现的定义异步代码的结构化方式感到兴奋。现在它终于来了,我们可以用 async-await 简化我们的代码,使我们的异步代码更容易阅读。

什么是 async?

async 是异步的意思,可以看作是一个明确表示一个方法是执行异步工作的一个属性。这样一个方法的例子看起来如下:

func fetchImages() async throws -> [UIImage] {
// .. 执行数据请求
}
fetchImages 方法被定义为异步且可以抛出异常,这意味着它正在执行一个可失败的异步作业。如果一切顺利,该方法将返回一组图像,如果出现问题,则抛出错误。

async 如何取代完成回调闭包

async 方法取代了经常看到的完成回调。完成回调在 Swift 中很常见,用于从异步任务中返回,通常与一个结果类型的参数相结合。上述方法一般会被写成这样:

func fetchImages(completion: (Result<[UIImage], Error>) -> Void) {
// .. 执行数据请求
}
在如今的 Swift 版本中,使用完成闭包来定义方法仍然是可行的,但它有一些缺点,async 却刚好可以解决。

你必须确保自己在每个可能的退出方法中调用完成闭包。如果不这样做,可能会导致应用程序无休止地等待一个结果。

闭包代码比较难阅读。与结构化并发相比,对执行顺序的推理并不那么容易。

需要使用弱引用weak references 来避免循环引用。

实现者需要对结果进行切换以获得结果。无法从实现层面使用try catch 语句。

这些缺点是基于使用相对较新的 Result 枚举的闭包版本。很可能很多项目仍然在使用完成回调,而没有使用这个枚举:

func fetchImages(completion: ([UIImage]?, Error?) -> Void) {
// .. 执行数据请求
}
像这样定义一个方法使我们很难推理出调用者一方的结果。value​ 和 error 都是可选的,这要求我们在任何情况下都要进行解包。对这些可选项解包会导致更多的代码混乱,这对提高可读性没有帮助。

什么是 await?

await 是用于调用异步方法的关键字。你可以把它们 (async-await) 看作是 Swift 中最好的朋友,因为一个永远不会离开另一个,你基本上可以这样说:

"Await 正在等待来自他的伙伴 async 的回调"

尽管这听起来很幼稚,但这并不是骗人的! 我们可以通过调用我们先前定义的异步方法 fetchImages 方法来看一个例子:

do {
let images = try await fetchImages()
print("Fetched \(images.count) images.")
} catch {
print("Fetching images failed with error \(error)")
}
也许你很难相信,但上面的代码例子是在执行一个异步任务。使用 await​ 关键字,我们告诉我们的程序等待 fetchImages 方法的结果,只有在结果到达后才继续。这可能是一个图像集合,也可能是一个在获取图像时出了什么问题的错误。

什么是结构化并发?

使用 async-await 方法调用的结构化并发使得执行顺序的推理更加容易。方法是线性执行的,不用像闭包那样来回走动。

为了更好地解释这一点,我们可以看看在结构化并发到来之前,我们如何调用上述代码示例:

// 1. 调用这个方法
fetchImages { result in
// 3. 异步方法内容返回
switch result {
case .success(let images):
print("Fetched \(images.count) images.")
case .failure(let error):
print("Fetching images failed with error \(error)")
}
}
// 2. 调用方法结束
正如你所看到的,调用方法在获取图像之前结束。最终,我们收到了一个结果,然后我们回到了完成回调的流程中。这是一个非结构化的执行顺序,可能很难遵循。如果我们在完成回调中执行另一个异步方法,毫无疑问这会增加另一个闭包回调:

// 1. 调用这个方法
fetchImages { result in
// 3. 异步方法内容返回
switch result {
case .success(let images):
print("Fetched \(images.count) images.")

// 4. 调用 resize 方法
resizeImages(images) { result in
// 6. Resize 方法返回
switch result {
case .success(let images):
print("Decoded \(images.count) images.")
case .failure(let error):
print("Decoding images failed with error \(error)")
}
}
// 5. 获图片方法返回
case .failure(let error):
print("Fetching images failed with error \(error)")
}
}
// 2. 调用方法结束
每一个闭包都会增加一层缩进,这使得我们更难理解执行的顺序。

通过使用 async-await 重写上述代码示例,最好地解释了结构化并发的作用。

do {
// 1. 调用这个方法
let images = try await fetchImages()
// 2.获图片方法返回

// 3. 调用 resize 方法
let resizedImages = try await resizeImages(images)
// 4.Resize 方法返回

print("Fetched \(images.count) images.")
} catch {
print("Fetching images failed with error \(error)")
}
// 5. 调用方法结束
执行的顺序是线性的,因此,容易理解,容易推理。当我们有时还在执行复杂的异步任务时,理解异步代码会更容易。

调用异步方法

在一个不支持并发的函数中调用异步方法

在第一次使用 async-await 时,你可能会遇到这样的错误。

当我们试图从一个不支持并发的同步调用环境中调用一个异步方法时,就会出现这个错误。我们可以通过将我们的 fetchData 方法也定义为异步来解决这个错误:

func fetchData() async {
do {
try await fetchImages()
} catch {
// .. handle error
}
}
然而,这将把错误转移到另一个地方。相反,我们可以使用 Task.init 方法,从一个支持并发的新任务中调用异步方法,并将结果分配给我们视图模型中的一个属性:

final class ContentViewModel: ObservableObject {

@Published var images: [UIImage] = []

func fetchData() {
Task.init {
do {
self.images = try await fetchImages()
} catch {
// .. handle error
}
}
}
}
使用尾随闭包的异步方法,我们创建了一个环境,在这个环境中我们可以调用异步方法。一旦异步方法被调用,获取数据的方法就会返回,之后所有的异步回调都会在闭包内发生。

采用 async-await

在一个现有项目中采用 async-await

当在现有项目中采用 async-await 时,你要注意不要一下子破坏所有的代码。在进行这样的大规模重构时,最好考虑暂时维护旧的实现,这样你就不必在知道新的实现是否足够稳定之前更新所有的代码。这与 SDK 中被许多不同的开发者和项目所使用的废弃方法类似。

显然,你没有义务这样做,但它可以使你更容易在你的项目中尝试使用 async-await。除此之外,Xcode 使重构你的代码变得超级容易,还提供了一个选项来创建一个单独的  async 方法:

每个重构方法都有自己的目的,并导致不同的代码转换。为了更好地理解其工作原理,我们将使用下面的代码作为重构的输入:

struct ImageFetcher {
func fetchImages(completion: @escaping (Result<[UIImage], Error>) -> Void) {
// .. 执行数据请求
}
}

将函数转换为异步 (Convert Function to Async)

第一个重构选项将 fetchImages 方法转换为异步变量,而不保留非异步变量。如果你不想保留原来的实现,这个选项将很有用。结果代码如下:

struct ImageFetcher {
func fetchImages() async throws -> [UIImage] {
// .. 执行数据请求
}
}

添加异步替代方案 (Add Async Alternative)

添加异步替代重构选项确保保留旧的实现,但会添加一个可用(available) 属性:

struct ImageFetcher {
@available(*, renamed: "fetchImages()")
func fetchImages(completion: @escaping (Result<[UIImage], Error>) -> Void) {
Task {
do {
let result = try await fetchImages()
completion(.success(result))
} catch {
completion(.failure(error))
}
}
}


func fetchImages() async throws -> [UIImage] {
// .. 执行数据请求
}
}
可用属性对于了解你需要在哪里更新你的代码以适应新的并发变量是非常有用的。虽然,Xcode 提供的默认实现并没有任何警告,因为它没有被标记为废弃的。要做到这一点,你需要调整可用标记,如下所示:

@available(*, deprecated, renamed: "fetchImages()")
使用这种重构选项的好处是,它允许你逐步适应新的结构化并发变化,而不必一次性转换你的整个项目。在这之间进行构建是很有价值的,这样你就可以知道你的代码变化是按预期工作的。利用旧方法的实现将得到如下的警告。

你可以在整个项目中逐步改变你的实现,并使用Xcode中提供的修复按钮来自动转换你的代码以利用新的实现。

添加异步包装器 (Add Async Wrapper)

最后的重构方法将使用最简单的转换,因为它将简单地利用你现有的代码:

struct ImageFetcher {
@available(*, renamed: "fetchImages()")
func fetchImages(completion: @escaping (Result<[UIImage], Error>) -> Void) {
// .. 执行数据请求
}

func fetchImages() async throws -> [UIImage] {
return try await withCheckedThrowingContinuation { continuation in
fetchImages() { result in
continuation.resume(with: result)
}
}
}
}
新增加的方法利用了 Swift 中引入的 withCheckedThrowingContinuation​ 方法,可以不费吹灰之力地转换基于闭包的方法。不抛出的方法可以使用 withCheckedContinuation,其工作原理与此相同,但不支持抛出错误。

这两个方法会暂停当前任务,直到给定的闭包被调用以触发 async-await 方法的继续。换句话说:你必须确保根据你自己的基于闭包的方法的回调来调用 continuation​ 闭包。在我们的例子中,这归结为用我们从最初的  fetchImages 回调返回的结果值来调用继续。

为你的项目选择正确的 async-await 重构方法

这三个重构选项应该足以将你现有的代码转换为异步的替代品。根据你的项目规模和你的重构时间,你可能想选择一个不同的重构选项。不过,我强烈建议逐步应用改变,因为它允许你隔离改变的部分,使你更容易测试你的改变是否如预期那样工作。

解决错误

解决 "Reference to captured parameter ‘self’ in concurrently-executing code "错误

在使用异步方法时,另一个常见的错误是下面这个:

“Reference to captured parameter ‘self’ in concurrently-executing code”

这大致意思是说我们正试图引用一个不可变的self实例。换句话说,你可能是在引用一个属性或一个不可变的实例,例如,像下面这个例子中的结构体:

不支持从异步执行的代码中修改不可变的属性或实例。

可以通过使属性可变或将结构体更改为引用类型(如类)来修复此错误。

枚举的终点

async-await 将是Result枚举的终点吗?

我们已经看到,异步方法取代了利用闭包回调的异步方法。我们可以问自己,这是否会是 Swift 中 Result 枚举[2]的终点。最终我们会发现,我们真的不再需要它们了,因为我们可以利用 try-catch 语句与 async-await 相结合。

Result 枚举不会很快消失,因为它仍然在整个 Swift 项目的许多地方被使用。然而,一旦 async-await 的采用率越来越高,我就不会惊讶地看到它被废弃。就我个人而言,除了完成回调,我没有在其他地方使用结果枚举。一旦我完全使用 async-await,我就不会再使用这个枚举了。

结论

Swift 中的 async-await 允许结构化并发,这将提高复杂异步代码的可读性。不再需要完成闭包,而在彼此之后调用多个异步方法的可读性也大大增强。一些新的错误类型可能会发生,通过确保异步方法是从支持并发的函数中调用的,同时不改变任何不可变的引用,这些错误将可以得到解决。

参考资料

[1]Swift Concurrency Manifesto by Chris Lattner: https://gist.github.com/lattner/31ed37682ef1576b16bca1432ea9f782

[2]Result 枚举: https://www.avanderlee.com/swift/result-enum-type/

有关Swift 中的 Async/Await ——代码实例详解的更多相关文章

  1. ruby - 如何从 ruby​​ 中的字符串运行任意对象方法? - 2

    总的来说,我对ruby​​还比较陌生,我正在为我正在创建的对象编写一些rspec测试用例。许多测试用例都非常基础,我只是想确保正确填充和返回值。我想知道是否有办法使用循环结构来执行此操作。不必为我要测试的每个方法都设置一个assertEquals。例如:describeitem,"TestingtheItem"doit"willhaveanullvaluetostart"doitem=Item.new#HereIcoulddotheitem.name.shouldbe_nil#thenIcoulddoitem.category.shouldbe_nilendend但我想要一些方法来使用

  2. ruby - 其他文件中的 Rake 任务 - 2

    我试图在一个项目中使用rake,如果我把所有东西都放到Rakefile中,它会很大并且很难读取/找到东西,所以我试着将每个命名空间放在lib/rake中它自己的文件中,我添加了这个到我的rake文件的顶部:Dir['#{File.dirname(__FILE__)}/lib/rake/*.rake'].map{|f|requiref}它加载文件没问题,但没有任务。我现在只有一个.rake文件作为测试,名为“servers.rake”,它看起来像这样:namespace:serverdotask:testdoputs"test"endend所以当我运行rakeserver:testid时

  3. ruby-on-rails - Ruby net/ldap 模块中的内存泄漏 - 2

    作为我的Rails应用程序的一部分,我编写了一个小导入程序,它从我们的LDAP系统中吸取数据并将其塞入一个用户表中。不幸的是,与LDAP相关的代码在遍历我们的32K用户时泄漏了大量内存,我一直无法弄清楚如何解决这个问题。这个问题似乎在某种程度上与LDAP库有关,因为当我删除对LDAP内容的调用时,内存使用情况会很好地稳定下来。此外,不断增加的对象是Net::BER::BerIdentifiedString和Net::BER::BerIdentifiedArray,它们都是LDAP库的一部分。当我运行导入时,内存使用量最终达到超过1GB的峰值。如果问题存在,我需要找到一些方法来更正我的代

  4. ruby-on-rails - Rails 3 中的多个路由文件 - 2

    Rails2.3可以选择随时使用RouteSet#add_configuration_file添加更多路由。是否可以在Rails3项目中做同样的事情? 最佳答案 在config/application.rb中:config.paths.config.routes在Rails3.2(也可能是Rails3.1)中,使用:config.paths["config/routes"] 关于ruby-on-rails-Rails3中的多个路由文件,我们在StackOverflow上找到一个类似的问题

  5. ruby - 如何在 buildr 项目中使用 Ruby 代码? - 2

    如何在buildr项目中使用Ruby?我在很多不同的项目中使用过Ruby、JRuby、Java和Clojure。我目前正在使用我的标准Ruby开发一个模拟应用程序,我想尝试使用Clojure后端(我确实喜欢功能代码)以及JRubygui和测试套件。我还可以看到在未来的不同项目中使用Scala作为后端。我想我要为我的项目尝试一下buildr(http://buildr.apache.org/),但我注意到buildr似乎没有设置为在项目中使用JRuby代码本身!这看起来有点傻,因为该工具旨在统一通用的JVM语言并且是在ruby中构建的。除了将输出的jar包含在一个独特的、仅限ruby​​

  6. ruby-on-rails - Rails 源代码 : initialize hash in a weird way? - 2

    在rails源中:https://github.com/rails/rails/blob/master/activesupport/lib/active_support/lazy_load_hooks.rb可以看到以下内容@load_hooks=Hash.new{|h,k|h[k]=[]}在IRB中,它只是初始化一个空哈希。和做有什么区别@load_hooks=Hash.new 最佳答案 查看rubydocumentationforHashnew→new_hashclicktotogglesourcenew(obj)→new_has

  7. ruby-on-rails - Rails - 一个 View 中的多个模型 - 2

    我需要从一个View访问多个模型。以前,我的links_controller仅用于提供以不同方式排序的链接资源。现在我想包括一个部分(我假设)显示按分数排序的顶级用户(@users=User.all.sort_by(&:score))我知道我可以将此代码插入每个链接操作并从View访问它,但这似乎不是“ruby方式”,我将需要在不久的将来访问更多模型。这可能会变得很脏,是否有针对这种情况的任何技术?注意事项:我认为我的应用程序正朝着单一格式和动态页面内容的方向发展,本质上是一个典型的网络应用程序。我知道before_filter但考虑到我希望应用程序进入的方向,这似乎很麻烦。最终从任何

  8. ruby-on-rails - Rails 3.2.1 中 ActionMailer 中的未定义方法 'default_content_type=' - 2

    我在我的项目中添加了一个系统来重置用户密码并通过电子邮件将密码发送给他,以防他忘记密码。昨天它运行良好(当我实现它时)。当我今天尝试启动服务器时,出现以下错误。=>BootingWEBrick=>Rails3.2.1applicationstartingindevelopmentonhttp://0.0.0.0:3000=>Callwith-dtodetach=>Ctrl-CtoshutdownserverExiting/Users/vinayshenoy/.rvm/gems/ruby-1.9.3-p0/gems/actionmailer-3.2.1/lib/action_mailer

  9. ruby-on-rails - 如何使用 instance_variable_set 正确设置实例变量? - 2

    我正在查看instance_variable_set的文档并看到给出的示例代码是这样做的:obj.instance_variable_set(:@instnc_var,"valuefortheinstancevariable")然后允许您在类的任何实例方法中以@instnc_var的形式访问该变量。我想知道为什么在@instnc_var之前需要一个冒号:。冒号有什么作用? 最佳答案 我的第一直觉是告诉你不要使用instance_variable_set除非你真的知道你用它做什么。它本质上是一种元编程工具或绕过实例变量可见性的黑客攻击

  10. ruby 正则表达式 - 如何替换字符串中匹配项的第 n 个实例 - 2

    在我的应用程序中,我需要能够找到所有数字子字符串,然后扫描每个子字符串,找到第一个匹配范围(例如5到15之间)的子字符串,并将该实例替换为另一个字符串“X”。我的测试字符串s="1foo100bar10gee1"我的初始模式是1个或多个数字的任何字符串,例如,re=Regexp.new(/\d+/)matches=s.scan(re)给出["1","100","10","1"]如果我想用“X”替换第N个匹配项,并且只替换第N个匹配项,我该怎么做?例如,如果我想替换第三个匹配项“10”(匹配项[2]),我不能只说s[matches[2]]="X"因为它做了两次替换“1fooX0barXg

随机推荐