swift - 写入后台 Realm 的数据不能立即用于主 Realm

Question

我有如下设置:

// Queues
private static let mainQueue = dispatch_get_main_queue()
private static let writeQueue = dispatch_queue_create("com.tablelist.Tablelist.queue.realm.write", DISPATCH_QUEUE_SERIAL)

// Realms
private static let defaultRealm: Realm = try! Realm()

private static func getDefaultRealm(block: (Realm) -> ()) {
    Dispatch.async(mainQueue) {
        block(defaultRealm)
    }
}

private static func getWriteRealm(block: (Realm) -> ()) {
    Dispatch.async(writeQueue) {
        block(try! Realm())
    }
}

最初我有一个writeRealm 但由于 GCD 不保证队列中的 block 在哪个线程运行，我被迫每次都创建一个新的 Realm写函数。

然后我有一个公共(public)函数:

/**
    Asynchronously write data to the realm
*/
public static func write(block: (Realm) -> ()) -> Promise<Realm> {
    let promise = Promise<Realm>()

    getWriteRealm { writeRealm in
        do {
            try writeRealm.write {
                block(writeRealm)
            }
            getDefaultRealm { realm in
                promise.resolve(realm)
            }
        }
        catch {
            Dispatch.main {
                promise.resolve(error)
            }
        }
    }

    return promise
}

这允许调用者传入一个可以进行任何导入的 block ，然后在 promise 解析时在主线程上获取任何导入。问题是，有时导入的数据可用于主线程上的 Realm，有时则不能。这里有更好的方法吗？

编辑:澄清一下，如果我更改 write 函数以在两种情况下获取默认 Realm ，我的所有测试都会通过。

解决方案:

private static func getDefaultRealm(block: (Realm) -> ()) {
    Dispatch.async(mainQueue) {
        defaultRealm.refresh() // refresh the realm to bring to most recent state
        block(defaultRealm)
    }
}

private static func getWriteRealm(block: (Realm) -> ()) {
    Dispatch.async(writeQueue) {
        let realm = try! Realm()
        realm.refresh() // refresh the realm to bring to most recent state
        block(realm)
    }
}

解决方案 2:(进一步简化后)

private static func getDefaultRealm(block: (Realm) -> ()) {
    let queue = dispatch_get_main_queue()
    getRealm(queue, block: block)
}

private static func getWriteRealm(block: (Realm) -> ()) {
    let queue = dispatch_queue_create("com.tablelist.Tablelist.queue.realm.write", nil)
    getRealm(queue, block: block)
}

private static func getRealm(queue: dispatch_queue_t, block: (Realm) -> ()) {
    Dispatch.async(queue) {
        let realm = try! Realm()
        realm.refresh()
        block(realm)
    }
}

Answer 1

tl；博士；调用 Realm.refresh() 将事务推进到最新状态。

Realm 的事务是独立的以提供自洽性。这允许随时在任何线程上执行事务，而无需您显式锁定或使用其他类型的资源协调。

Realm 中的读取和写入事务均基于首次初始化时最近的成功写入提交，并保持该版本直到刷新。除非 Realm 的 autorefresh 属性设置为 false，否则 Realms 会在每次运行循环迭代开始时自动刷新。如果一个线程没有运行循环(后台线程通常是这种情况)，则必须手动调用 Realm.refresh() 以便将事务推进到最新状态。

当写入事务被提交时， Realm 也会被刷新(Realm.commitWrite())。