ios - 尝试使用 Grand Central Dispatch 执行 Realm 事务时出现 RLMException

Question

我在我的 AppDelegate 中将这两个声明为全局变量

var realmdb: RLMRealm!
var realmQueue = dispatch_queue_create("com.pesto.realmdb", DISPATCH_QUEUE_SERIAL)

在我的 application(_, didFinishLaunchingWithOptions: _) 中，我将 defaultRealm 的引用设置为我的全局 realmdb，如下所示:

 dispatch_async(realmQueue) {
     realmdb = RLMRealm.defaultRealm()
 }

在我代码的另一个类中我有这个方法:

private func handleChatMessage(message: PSTChatMsg) {

    // check if there is a channel environment for this message
    PSTChatHelpers.getChannelEnvironmentForChannelName(message.channel) { channelEnvironments in

        if channelEnvironments.count == 0 {

            log.verbose("Channel environment for \(message.channel) does not exists. Creating...")

            let newChannelEnvironment = PSTChatHelpers.createChannelEnvironmentFromMessage(message)
            PSTChatHelpers.persistChannelEnvironmentChanges(newChannelEnvironment)

        } else {

            log.verbose("Pushing message to channel environment")

        }

    }
}

调用方法是这样实现的:

 class func getChannelEnvironmentForChannelName(channelName: String, withCompletionHandler handler: (results: RLMResults) -> ()) {

    dispatch_async(realmQueue) {

        let predicate = NSPredicate(format: "channelName = %@", channelName)
        var channelEnv = PSTChannelEnvironment.objectsInRealm(realmdb, withPredicate: predicate)

        handler(results: channelEnv)
    }

}

 /**
    Creates a new PSTChannelEnvironment object wth values derived from passed PSTChatMsg

    :param: message a PSTChatMsg to derive channel environment values from
    :returns: The newly created PSTChannelEnvironment object
*/
class func createChannelEnvironmentFromMessage(message: PSTChatMsg) -> PSTChannelEnvironment {

    let channelEnvironment = PSTChannelEnvironment()

    channelEnvironment.channelName = message.channel
    channelEnvironment.associatedPlaceId = message.associatedPlaceId
    channelEnvironment.chattingWithUuid = ""
    channelEnvironment.chattingWithUsername = ""
    channelEnvironment.hasSessionEnded = false
    channelEnvironment.unreadMessages = 0

    return channelEnvironment

}

/**
    Commits the passed PSTChannelEnvironment in Realm database

    :param: The PSTChannelEnvironment to commit to Realm
*/
class func persistChannelEnvironmentChanges(channelEnvironment: PSTChannelEnvironment) {

    dispatch_async(realmQueue) {

        realmdb.beginWriteTransaction()
        realmdb.addObject(channelEnvironment)
        realmdb.commitWriteTransaction()

    }
}

我从 getChannelEnvironmentForChannelName() 方法中得到 RLMException，原因:“从不正确的线程访问 Realm ”。

我对如何使用 GCD 来处理我所有的 Realm 操作感到有点沮丧，因此非常感谢任何帮助!

Answer 1

由于通常线程和队列之间没有固定的关联(没有主队列，主队列只在主线程上运行，反之亦然)，你不能只检索一个 RLMRealm 实例通过调度到您的队列并缓存它。 GCD 不保证同一个队列将再次由同一个线程执行。

我建议通过非缓存工厂方法来引用您的 Realm :

var realmdb : RLMRealm {
  return RLMRealm.defaultRealm()
}

不用担心，在 RLMRealm 上定义的工厂方法本身已经实现了一个缓存策略，因此这个操作不会太昂贵，您仍然可以在每次使用时将实例缓存在本地 var 中。

如果你想传递它来解耦类之间的关系，你仍然可以将它写成一个函数类型:

var realmdb : () -> RLMRealm {
    return { RLMRealm.defaultRealm() }
}