android开发realm多线程操作,android – 处理多线程和Realm的正确方法是什么?

在我的

Android应用程序上,我有一个数据访问层,我在每个数据存储类上都有以下属性

Realm realm = Realm.getDefaultInstance();

我的问题是当我尝试从不同的线程调用任何数据存储方法时.然后我明白了

Realm objects can only be accessed on the thread they were created.

我已经读过我应该在新线程上创建一个新的Realm实例.问题是数据访问层没有线程感知,它不知道它是从main调用还是分离,在我看来它会闻到添加逻辑来检查.

我在这里检查了不同的问题,并在github上填写了问题,但我不清楚处理这种情况的正确方法是什么.我不认为我正在处理一个奇怪的场景……

编辑

我的arquitecture是Fragment,其中包含一个包含DataStore的Presenter.

我检测到一个非常长的运行过程,所以我在演示者上将它移动到这样的分离线程

Thread thread = new Thread(new Runnable() {

@Override

public void run() {

// Events is a collection of DTOs, they are not Realm objects (converted from Realm object to DTO inside dataStore)

events = dataStore.getEvents(filterTerm);

view.getActivity().runOnUiThread(new Runnable() {

@Override

public void run() {

if (events.size() > 0) {

view.showEvents(events);

}

}

});

}

});

thread.start();

编辑

添加连续执行的3个查询.它们来自3种不同的方法

查询1

final RealmResults results = query.findAllAsync();

results.addChangeListener(new RealmChangeListener() {

@Override

public void onChange() {

....

}

});

查询2

final RealmResults result = realm.where(type).findAllAsync();

result.addChangeListener(new RealmChangeListener() {

@Override

public void onChange() {

...

}

});

查询3

final RealmResults results = query.findAllAsync();

results.addChangeListener(new RealmChangeListener() {

@Override

public void onChange() {

...

}

});