使用Room和RxJava的非法状态异常

Question

我在应用程序中访问房间DAOs时遇到问题。即使我通过rxjava在后台线程中执行操作，也会出现此错误：

java。lang.IllegalStateException:无法访问主线程上的数据库，因为它可能会长时间锁定UI

我试图在应用程序中通过MVP使用干净的体系结构，我称之为在后台线程中进行该操作的用例。

更多信息：

涉及的类别包括：

主持人。JAVA

更新密码。从用例扩展而来的java。JAVA

最后是ReciphaLocalDataSource.java

我需要一些帮助，提前谢谢。




Answer 1

使用RxJava并不意味着你在做异步过程，事实上RxJava默认是同步的。

如果你想让一个操作异步，你需要使用操作符subscribeOn，它将订阅你的observable在另一个线程中运行，或者使用observon指定你想要异步完成的操作。

一个例子

/**
 * Once that you set in your pipeline the observerOn all the next steps of your pipeline will be executed in another thread.
 * Shall print
 * First step main
 * Second step RxNewThreadScheduler-2
 * Third step RxNewThreadScheduler-1
 */
@Test
public void testObservableObserverOn() throws InterruptedException {
    Subscription subscription = Observable.just(1)
            .doOnNext(number -> System.out.println("First step " + Thread.currentThread()
                    .getName()))
            .observeOn(Schedulers.newThread())
            .doOnNext(number -> System.out.println("Second step " + Thread.currentThread()
                    .getName()))
            .observeOn(Schedulers.newThread())
            .doOnNext(number -> System.out.println("Third step " + Thread.currentThread()
                    .getName()))
            .subscribe();
    new TestSubscriber((Observer) subscription)
            .awaitTerminalEvent(100, TimeUnit.MILLISECONDS);
}

你可以在这里看到这两个例子https://github.com/politrons/reactive/blob/master/src/test/java/rx/observables/scheduler/ObservableAsynchronous.java

Answer 2

您正在使用的只是，它接受一个已经创建/计算的值。基本上，你在调用线程上进行计算，然后把结果包装成一个可观察的。（我无法想象为什么这种逻辑上的误解会如此频繁地出现，因为没有一种主流语言会在普通括号之间延迟计算。）

改为这样做：

@Override
public Observable<Boolean> updateRecipes(List<JsonRecipe> jsonRecipes) {
    return Observable.fromCallable(() -> {
        mRecipeDb.runInTransaction(() ->
            deleteOldAndInsertNewRecipesTransaction(jsonRecipes));
        return true;
    });
}