在使用copyFromRealm发送复制时，从错误的线程访问Realm会抛出异常。

Question

在使用copyFromRealm发送复制时，从错误的线程访问Realm会抛出异常。

6

当使用流式复制Realm对象而不是引用并在Schedulers.IO线程上观察它时，会出现著名的异常消息“从错误的线程访问Realm。 Realm对象只能在创建它们的线程中访问。”

这个复制品不应该是无线程的吗？我可以在一个线程上生成它并在另一个线程上处理它吗？

下面是我创建可观察对象的方式。

 public Observable<Brand> getAllBrands() {
    return realm.where(Brand.class)
            .findAll()
            .asObservable()
            .flatMap(Observable::from)
            .map(brand -> realm.copyFromRealm(brand));
}

以下是我对getAllBrands()函数的观察：

获取所有品牌函数。

 Observable<Brand> brandObservable = dataManager.getAllBrands();

    brandObservable.observeOn(AndroidSchedulers.mainThread())
            .subscribeOn(Schedulers.io())
            .subscribe(new Observer<Brand>() {
                @Override
                public void onCompleted() {
                    Log.d("reactive", "completed");
                }

                @Override
                public void onError(Throwable e) {
                    Log.d("reactive", e.getMessage());
                }

                @Override
                public void onNext(Brand brand) {
                    dataSource.add(brand.getName());
                    myAdapter.notifyDataSetChanged();
                }
            });

- sam33r

1

您使用的“realm”不在“io()”调度程序上。 - EpicPandaForce

2个回答

0

问题

我可以在一个线程中生成它，然后在另一个线程中处理它吗？

答案是否定的。您可以在这里阅读Realm的描述。

尽管Realm文件可以被多个线程同时访问，但是您不能在不同的线程之间传递Realms、Realm对象、查询和结果。线程示例展示了如何在多线程环境下使用Realm。

- ThaiPD

2

但问题是关于使用 copyFromRealm() 的分离对象，这些对象据说与 Realm 实例无关。 - EpicPandaForce

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Christian Melchior · Accepted Answer

您正在使用 UI 线程上的 Realm 实例，并在 schedulers.io 上进行订阅：

realm.where(Brand.class)
        .findAll()
        .asObservable()
        .flatMap(Observable::from)
        .map(brand -> realm.copyFromRealm(brand)) // realm instance on the wrong thread
        .subscribeOn(schedulers.io());

您需要的是一种将查询轻松移动到不同线程的方法，这个功能目前还在开发中: https://github.com/realm/realm-java/pull/1978。在此之前，您可以通过自己手动实现以下方式来解决：

public Observable<Brand> getAllBrands(final Realm realm) {
    return Observable.create(new Observable.OnSubscribe<List<Brand>>() {
        @Override
        public void call(final Subscriber<? super List<Brand>> subscriber) {
            Realm obsRealm = Realm.getInstance(realm.getConfiguration());
            final RealmResults<Brand> results = obsRealm.where(Brand.class).findAll();
            final RealmChangeListener listener = new RealmChangeListener() {
                @Override
                public void onChange() {
                    subscriber.onNext(realm.copyFromRealm(results));
                }
            };
            results.addChangeListener(listener);
            subscriber.add(Subscriptions.create(new Action0() {
                @Override
                public void call() {
                    realm.removeChangeListener(listener);
                    realm.close();
                }
            }));

        }
    })
    .flatMap(Observable::from);
}

请注意，Realm变更侦听器仅在Looper线程上工作，这意味着您可能需要将工作线程更改为H。

HandlerThread bgThread = new HandlerThread("workerThread");
Handler handler = new Handler(bgThread.getLooper());

getAllBrands(realm).subscribeOn(HandlerScheduler.from(handler));