是否可以将异步函数传递给 Swift 中的核心数据托管对象上下文？如果不是，那为什么？

Question

我已经寻找了一种将异步函数传递到核心数据托管对象上下文的方法，但仍然找不到。我怀疑新的异步/等待并发模型的某些部分我不理解，但我不知道它是什么。

我想做的事：

// Grab an moc
let moc = container.newBackgroundContext()

// Enter an async context
Task {

    await moc.perform {

        // Get some object
        let obj = moc.object(with: anObjectID)
        
        // This is not possible because NSManagedObjectContext.perform only accepts
        // a synchronous block
        await obj.doSomeLongRunningProcess()

    }
}

对我来说，这似乎是不可能的，这很奇怪。我不确定 Core Data api 中是否还没有它，因为 async/await 太新了，或者是否有一个很好的理由它不可能？

像这样将 doSomeLongRunningProcess 包装在 Task 中

await moc.perform {
    Task {
        let obj = moc.object(with: anObjectID)
        await obj.doSomeLongRunningProcess()
    }
}

不起作用，因为内部 Task 在不同的线程上运行，最终会出现 CoreData 不一致的情况。我有点希望它能继承上下文的线程，但事实并非如此。

我想要一种将异步函数传递给 ManagedObjectContext 的方法，但如果做不到，我想知道为什么它不起作用？

Answer 1

您无法直接从 perform 中调用 async 方法。它需要是同步方法，您不会等待。

你问：

...但是如果我想从 doSomeLongRunningProcess 中调用其他异步函数怎么办？

问题是，如果您在 perform 中遇到假设的 await 挂起点，而执行路径将挂起，则线程将可以自由执行该执行器上挂起的其他代码，而“继续”（暂停点之后的代码）将稍后运行。 （await 调用与 GCD sync 调用不同，而更像是延续的调度组 notify。）如果这种情况发生在内部执行，从理论上讲，该任务的完整性可能会被其他任务破坏，这些任务可能会在延续有机会运行之前溜进去。有关这些暂停点、延续等的详细信息，请参阅Swift 并发：幕后< /a>

我建议将 doSomeLongRunningProcess 更改为不是 async，并且如果可能的话，改为使用 Task { ... } 来自 doSomeLongRunningProcess。但是您不能让此方法成为async并且具有await挂起点。

有关将新的异步等待模式与 Swift 并发结合使用的更多信息，请参阅 WWDC 2021 视频 将核心数据并发引入 Swift 和 SwiftUI。

Answer 2

我花了一段时间试图解决这个问题。我能想到的是，鉴于 Swift Concurrency 的当前实现，目前这是不可能的。 Rob 的回答基本上仍然是正确的，但如果您想了解更多信息：

有人在 Swift 论坛上提出了类似的问题 如何使用 Swift 并发创建具有序列化访问的对象图，其中有详细介绍。

您还不能保证异步函数将在给定的执行器上运行。全局 Actor 使之成为可能，但它将您的模型限制为单个 Actor。这意味着您不能让一个实体在主线程上调用异步函数，而另一个实体在后台线程上调用它。

即使您可以使用 Actor 来保证序列化访问，当您遇到等待暂停点时，一切都会消失，此时执行将移动。

据我所知，Apple 甚至无法将 NSManagedObjectContext 更改为 Actor，因为您仍然无法保证传递给它的异步函数不会发生变化。 t 到达等待暂停点。必须将一些基本内容添加到 Swift 并发规范中。

我的解决方案：
我基本上删除了与 NSManagedObjects 交互的所有异步/等待方法。我将重新评估 Swift Concurrency 何时/是否允许自定义执行程序等。