Swift async/await 取代了 DispatchQueue.main.async

在新的 Swift 5.5 中使用 async/await 并发机制时如何返回主线程？我应该只用@MainActor 标记函数、类吗？ 我还能用吗DispatchQueue.main.async？会是正确的吗？因为新机制不使用 GCD 并且异步任务和线程之间没有像以前那样的映射？

例如我正在使用 SwiftUIList with refreshable

List { }
.refreshable {
    viewModel.fetchData()
}

这个可以吗

List { }
.refreshable {
    DispatchQueue.main.async {
      viewModel.fetchData()
    }
}

或者我需要在 ViewModel 类上添加 @MainActor ？ 我在项目中没有使用 async/await，因此仅使用 MainActor 来实现这个单一的可刷新似乎是多余的，我也不知道添加此类属性如何影响 ViewModel 类的其余方法和属性，他们现在使用合并。

但另一方面 Xcode 显示

运行时：SwiftUI：不从后台线程发布更改 允许；确保从主线程发布值（通过 诸如 receive(on:)) 等模型更新操作符。

此外，在将 @MainActor 添加到 ViewModel 后，我收到多个这样的警告

与全局参与者“MainActor”隔离的属性“标题”无法满足 协议的相应要求 'OnlineBankingListViewModelProtocol'

你问：

我还能用吗DispatchQueue.main.async?

如果您处于async方法并想要将某些内容分派到主队列，最字面的等效内容是：

MainActor.run { ... }

但更谨慎的做法是简单地将方法（或其类）标记为@MainActor。这不仅可以确保它在主线程上运行它，而且如果您尝试从错误的参与者调用它，您还会收到编译时警告。

因此，如果您的视图模型标记为@MainActor，手动运行任务MainActor变得不必要。在处理被观察对象的已发布属性时尤其如此。

例如，考虑：

@MainActor
class ViewModel: ObservableObject {
    @Published var values: [Int] = []

    func fetchData() async {
        let foo = await ...
        values = foo.values
    }
}

And then

struct ContentView: View {
    @ObservedObject var viewModel = ViewModel()

    var body: some View {
        List {
            ...
        }
        .refreshable {
            await viewModel.fetchData()
        }

    }
}

（注意，我做了fetchData an async方法和await它在里面refreshable以便旋转器准确反映何时async进程正在运行。）

观看 WWDC 2021 视频Swift 并发：更新示例应用程序 https://developer.apple.com/videos/play/wwdc2021/10194/。诚然，这说明了 UIKit 应用程序的转变，但包括以下示例@MainActor and MainActor.run.

注意，同时@MainActor，很大程度上消除了需要MainActor.run { … }，还有一些场景你可能会用到这个run图案。具体来说，如果您在其他演员身上并且想要运行，例如，三个单独的演员@MainActor在主线程上连续运行函数，您可以将它们的系列包装在一个单独的函数中MainActor.run { … }块，从而通过一次调度到主要参与者来运行所有三个，而不是三个单独的调用。

上面，我重点介绍了重要部分，但以下是我的完整 MCVE：

struct ContentView: View {
    @ObservedObject var viewModel = ViewModel()

    var body: some View {
        List {
            ForEach(viewModel.values, id: \.self) { value in
                Text("\(value)")
            }
        }
        .refreshable {
            await viewModel.fetchData()
        }

    }
}

struct Foo: Decodable{
    let json: [Int]
}

@MainActor
class ViewModel: ObservableObject {
    @Published var values: [Int] = []

    func fetchData() async {
        do {
            let foo = try await object(Foo.self, for: request)
            values = foo.json
        } catch {
            print(error)
        }
    }

    func object<T: Decodable>(_ type: T.Type, for request: URLRequest) async throws -> T {
        let (data, response) = try await URLSession.shared.data(for: request)

        guard let response = response as? HTTPURLResponse else {
            throw URLError(.badServerResponse)
        }

        guard 200 ... 299 ~= response.statusCode else {
            throw ApiError.failure(response.statusCode, data)
        }

        return try JSONDecoder().decode(T.self, from: data)
    }

    var request: URLRequest = {
        let url = URL(string: "https://httpbin.org/anything")!
        var request = URLRequest(url: url)
        request.httpMethod = "POST"
        request.httpBody = "[1,2,3,4,5]".data(using: .utf8)
        request.addValue("application/json", forHTTPHeaderField: "Content-Type")
        request.addValue("application/json", forHTTPHeaderField: "Accept")

        return request
    }()
}

enum ApiError: Error {
    case failure(Int, Data)
}