Realm从不正确的线程访问
背景
我在我的应用程序中使用Realm。 当数据加载后，它会经历强烈的处理，因此处理发生在后台线程上。
正在使用的编码模式是工作单元模式，Realm只存在于DataManager下的存储库中。 这里的想法是每个存储库可以有不同的数据库/文件存储解决方案。
我所尝试过的
下面是我在FooRespository类中的一些类似代码的例子。
这里的想法是获得Realm的一个实例，用于查询感兴趣对象的领域，返回它们并关闭领域实例。 请注意，这是同步的，并在最后将对象从Realm复制到非托管状态。
public Observable<List<Foo>> getFoosById(List<String> fooIds) {
Realm realm = Realm.getInstance(fooRealmConfiguration);
RealmQuery<Foo> findFoosByIdQuery = realm.where(Foo.class);
for(String id : fooIds) {
findFoosByIdQuery.equalTo(Foo.FOO_ID_FIELD_NAME, id);
findFoosByIdQuery.or();
}
return findFoosByIdQuery
.findAll()
.asObservable()
.doOnUnsubscribe(realm::close)
.filter(RealmResults::isLoaded)
.flatMap(foos -> Observable.just(new ArrayList<>(realm.copyFromRealm(foos))));
}
此代码稍后通过RxJava与重处理代码一起使用：
dataManager.getFoosById(foo)
.flatMap(this::processtheFoosInALongRunningProcess)
.subscribeOn(Schedulers.io()) //could be Schedulers.computation() etc
.subscribe(tileChannelSubscriber);
阅读完文档后，我的信念是上述应该可以工作，因为它不是异步的，因此不需要循环线程。 我在同一个线程中获得领域的实例，因此它不在线程之间传递，也不是对象。
问题
当以上执行我得到
Realm从不正确的线程访问。 领域对象只能在创建它们的线程上访问。
这看起来不正确。 我唯一能想到的就是Realm实例池正在让我使用主线程从另一个进程创建的现有实例。
凯如此
return findFoosByIdQuery
.findAll()
.asObservable()
这发生在UI线程上，因为那是你从最初调用它的地方
.subscribeOn(Schedulers.io())
Aaaaand然后你在Schedulers.io()上修补它们。
不，这不是一回事！
尽管我不喜欢从零拷贝数据库复制的方法，但是您当前的方法充斥着由于滥用realmResults.asObservable()而导致的问题，因此，您的代码应该是：
public Observable<List<Foo>> getFoosById(List<String> fooIds) {
return Observable.defer(() -> {
try(Realm realm = Realm.getInstance(fooRealmConfiguration)) { //try-finally also works
RealmQuery<Foo> findFoosByIdQuery = realm.where(Foo.class);
for(String id : fooIds) {
findFoosByIdQuery.equalTo(FooFields.ID, id);
findFoosByIdQuery.or(); // please guarantee this works?
}
RealmResults<Foo> results = findFoosByIdQuery.findAll();
return Observable.just(realm.copyFromRealm(results));
}
}).subscribeOn(Schedulers.io());
}
请注意，您正在所有RxJava处理管道之外创建实例。 因此，在调用getFoosById()时，主线程（或任何线程getFoosById() 。
仅仅因为该方法返回一个Observable并不意味着它在另一个线程上运行。 只有由getFoosById()方法的最后一条语句创建的Observable的处理管道在正确的线程（ filter() ， flatMap()和调用者完成的所有处理）上运行。
因此，您必须确保调用getFoosById()已在Schedulers.io()所使用的线程上完成。
实现这一点的一种方法是使用Observable.defer() ：
Observable.defer(() -> dataManager.getFoosById(foo))
.flatMap(this::processtheFoosInALongRunningProcess)
.subscribeOn(Schedulers.io()) //could be Schedulers.computation() etc
.subscribe(tileChannelSubscriber);