Несогласованность базы данных MagicalRecord с NSFetchedResultsController

Итак, я нашел причину сбоев: хотя mr_saveToPersistentStoreAndWait ожидает, пока изменения будут сохранены в rootSavingContext, он не ждет, пока они не будут объединены в defaultContext (если они были сделаны контекстом частной очереди). Если rootSavingContext был изменен другим сохранением до того, как основной контекст очереди объединит старые изменения в основном потоке, слияние будет повреждено (изменения в уведомлении NSManagedObjectContextDidSave не соответствуют текущему состоянию контекста rootSavingContext во внутреннем rootContextDidSave: методе MagicalRecord).

Объяснение предлагаемого мной решения:

1. DatabaseSavingManager содержит контекст сохранения частной очереди, который будет использоваться для всех сохранений в приложении (возможно, это недостаток, если вы хотите использовать несколько контекстов сохранения, но этого достаточно для моих нужд - сохранения происходят в фоновом режиме и поддерживается согласованность). Как прокомментировал @Sneak, нет причин использовать фоновую последовательную очередь, которая создает несколько контекстов и ждет их завершения (это то, что я изначально делал), потому что NSManagedObjectContext имеет свою собственную последовательную очередь, поэтому теперь я использовал один контекст, который создается на основной поток и, следовательно, всегда должен вызываться из основного потока (используя perform(block:), чтобы избежать блокировки основного потока).

2. После сохранения в постоянное хранилище контекст сохранения ожидает NSManagedObjectContextObjectsDidChange уведомления от defaultContext, чтобы он знал, что defaultContext объединил изменения. Вот почему никакие другие сохранения, кроме использования контекста сохранения DatabaseSavingManager, не разрешены, потому что они могут запутать процесс ожидания.

Вот код DatabaseSavingManager:

import Foundation
import CoreData

class DatabaseSavingManager: NSObject {
    static let shared = DatabaseSavingManager()

    fileprivate let savingDispatchGroup = DispatchGroup()
    fileprivate var savingDispatchGroupEntered = false

    fileprivate lazy var savingContext: NSManagedObjectContext = {
        if !Thread.current.isMainThread {
            var context: NSManagedObjectContext!
            DispatchQueue.main.sync {
                context = NSManagedObjectContext.mr_()
            }
            return context
        }
        else {
            return NSManagedObjectContext.mr_()
        }
    }()

    override init() {
        super.init()
        NotificationCenter.default.addObserver(self, selector: #selector(defaultContextDidUpdate(notification:)), name: NSNotification.Name.NSManagedObjectContextObjectsDidChange, object: NSManagedObjectContext.mr_default())
    }

    deinit {
        NotificationCenter.default.removeObserver(self)
    }

    func save(block: @escaping (NSManagedObjectContext) -> ()) {
        guard Thread.current.isMainThread else {
            DispatchQueue.main.async {
                self.save(block: block)
            }
            return
        }

        let moc = self.savingContext
        self.savingContext.perform {
            block(self.savingContext)
            self.saveToPersistentStoreAndWait()
        }
    }

    func saveAndWait(block:  @escaping (NSManagedObjectContext) -> ()) {
        if Thread.current.isMainThread {
            self.savingContext.performAndWait {
                block(self.savingContext)
                self.saveToPersistentStoreAndWait()
            }
        }
        else {
            let group = DispatchGroup()
            group.enter()
            DispatchQueue.main.async {
                self.savingContext.perform {
                    block(self.savingContext)
                    self.saveToPersistentStoreAndWait()
                    group.leave()
                }
            }
            group.wait()
        }
    }

    fileprivate func saveToPersistentStoreAndWait() {
        if self.savingContext.hasChanges {
            self.savingDispatchGroupEntered = true
            self.savingDispatchGroup.enter()
            self.savingContext.mr_saveToPersistentStoreAndWait()
            self.savingDispatchGroup.wait()
        }
    }

    @objc fileprivate func defaultContextDidUpdate(notification: NSNotification) {
        if self.savingDispatchGroupEntered {
            self.savingDispatchGroup.leave()
            self.savingDispatchGroupEntered = false
        }
    }
}

И пример того, как его использовать (NSFetchedResultsController больше не вылетает; можно вызывать из любого потока, также очень часто):

    DatabaseSavingManager.shared.save { (moc) in
        for song in CDSong.mr_findAll(in: moc)! {
            let song = song as! CDSong
            let voters = song.voters!
            for voter in voters {
                (voter as! CDVoter).mr_deleteEntity(in: moc)
            }

            for _ in 1...4 {
                if arc4random()%2 == 0 {
                    let voter = CDVoter.mr_createEntity(in: moc)!
                    voter.name = String(UnicodeScalar(UInt8(arc4random()%26+65)))
                    voter.votedSong = song
                }
            }
        }
    }

Конечно, это точно не самое элегантное решение, просто первое, что пришло мне в голову, поэтому приветствуются другие подходы.