多线程核心数据有时 returns nil 属性

Question

我是核心数据的新手。我有一个使用核心数据作为本地存储的应用程序。写入和读取核心数据由后台线程完成。虽然这通常有效，但在极少数情况下，获取的数据是错误的，即获取的实体的属性是 nil.
为了检查情况，我写了一个启动 2 个异步线程的单元测试：一个从核心数据中不断获取，另一个通过首先删除所有数据然后存储新数据来不断覆盖这些数据。
这个测试很快就会引发错误，但我不知道为什么。当然我猜这是一个多线程问题，但我不明白为什么，因为获取和删除+写入是在单个 persistentContainer.
的单独托管上下文中完成的很抱歉，下面的代码很长，虽然缩短了，但我认为没有它就无法确定问题所在。
非常欢迎任何帮助！

这是我获取数据的函数：

func fetchShoppingItems(completion: @escaping (Set<ShoppingItem>?, Error?) -> Void) {
    persistentContainer.performBackgroundTask { (managedContext) in 
        let fetchRequest: NSFetchRequest<CDShoppingItem> = CDShoppingItem.fetchRequest()
        do {
            let cdShoppingItems: [CDShoppingItem] = try managedContext.fetch(fetchRequest)
            for nextCdShoppingItem in cdShoppingItems {
                nextCdShoppingItem.managedObjectContext!.performAndWait {
                    let nextname = nextCdShoppingItem.name! // Here, sometimes name is nil
                } // performAndWait
            } // for all cdShoppingItems
            completion(nil, nil)
            return
        } catch let error as NSError {
            // error handling
            completion(nil, error)
            return
        } // fetch error
    } // performBackgroundTask
} // fetchShoppingItems

我已经评论了有时会导致测试崩溃的行，因为 name 是 nil。

这是我存储数据的函数：

func overwriteCD(shoppingItems: Set<ShoppingItem>,completion: @escaping () -> Void) {
    persistentContainer.performBackgroundTask { (managedContext) in 
        self.deleteAllCDRecords(managedContext: managedContext, in: "CDShoppingItem")
        let cdShoppingItemEntity = NSEntityDescription.entity(forEntityName: "CDShoppingItem",in: managedContext)!
        for nextShoppingItem in shoppingItems {
            let nextCdShoppingItem = CDShoppingItem(entity: cdShoppingItemEntity,insertInto: managedContext)
            nextCdShoppingItem.name = nextShoppingItem.name
        } // for all shopping items
        self.saveManagedContext(managedContext: managedContext)
        completion()
    } // performBackgroundTask
} // overwriteCD  

func deleteAllCDRecords(managedContext: NSManagedObjectContext, in entity: String) {
    let deleteFetch = NSFetchRequest<NSFetchRequestResult>(entityName: entity)
    let deleteRequest = NSBatchDeleteRequest(fetchRequest: deleteFetch)
    deleteRequest.resultType = .resultTypeObjectIDs
    do {
        let result = try managedContext.execute(deleteRequest) as? NSBatchDeleteResult
        let objectIDArray = result?.result as? [NSManagedObjectID]
        let changes = [NSDeletedObjectsKey: objectIDArray]
        NSManagedObjectContext.mergeChanges(fromRemoteContextSave: changes as [AnyHashable: Any], into: [managedContext])
    } catch let error as NSError {
        // error handling
    }
} // deleteAllCDRecords

func saveManagedContext(managedContext: NSManagedObjectContext) {
    if !managedContext.hasChanges { return }
    do {
        try managedContext.save()
    } catch let error as NSError {
        // error handling
    }
} // saveManagedContext

Answer 1

您确定 name 不是所有请求实体的零吗？只需使用 guard-let 来避免 ! 作为可选变量。此外，! 展开可选变量的方法并不安全，尤其是当您无法确定数据源时。

Answer 2

我的代码的问题显然是竞争条件：
当“fetch”线程获取核心数据记录，并尝试将属性分配给属性时，“store”线程删除了记录。
这显然释放了属性对象，因此 nil 被存储为属性.
我认为 persistentContainer 会自动阻止这种情况，但事实并非如此。

解决方案是在并发串行队列中执行persistentContainer的两个后台线程，同步执行“获取”线程，异步执行“存储”线程有屏障。
因此，可以执行并发提取，而存储等待直到所有当前提取完成。

并发串行队列定义为

let localStoreQueue = DispatchQueue(label: "com.xxx.yyy.LocalStore.localStoreQueue", 
    attributes: .concurrent)

编辑：
在下面的获取和存储函数中，我将核心数据函数 persistentContainer.performBackgroundTask 移到了 localStoreQueue 中。如果它像我原来的答案那样在外面，localStoreQueue.async(flags: .barrier) 中的存储代码将设置一个新线程，从而在创建它的另一个线程中使用 managedContext，这是一个核心数据多线程错误.

“获取”线程修改为

localStoreQueue.sync {
  self.persistentContainer.performBackgroundTask { (managedContext) in
    let fetchRequest: NSFetchRequest<CDShoppingItem> = CDShoppingItem.fetchRequest()
    //…
  } // performBackgroundTask  
} // localStoreQueue.sync

并将“存储”线程作为

localStoreQueue.async(flags: .barrier) {
  self.persistentContainer.performBackgroundTask { (managedContext) in
    self.deleteAllCDRecords(managedContext: managedContext, in: "CDShoppingItem")
    //…
  } // performBackgroundTask
} // localStoreQueue.async

多线程核心数据有时 returns nil 属性

Multi-threaded core data sometimes returns nil properties

multithreading

core-data

background-process

swift