在我的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<Event> results = query.findAllAsync();
results.addChangeListener(new RealmChangeListener() {
    @Override
    public void onChange() {
        ....
    }
});

查询2

final RealmResults<T> result = realm.where(type).findAllAsync();
result.addChangeListener(new RealmChangeListener() {
    @Override
    public void onChange() {
        ...
    }
});

查询3

final RealmResults<PresentationSpeaker> results = query.findAllAsync();
results.addChangeListener(new RealmChangeListener() {
    @Override
    public void onChange() {
        ...
    }
});

解决方法:

通常自定义让您的DataStore是异步的,以避免您现在遇到的问题：操作需要很长时间,并且您必须创建自定义线程并使用postRunnable.这应该是DataStore关注的内容,而不是应该在UI线程上运行的Presenter和UI.一种解决方案是让您的数据存储区变为异步,或者通过自己实现一些观察者模式或使用RxJava.然后,您可以使用Realms异步API(https://realm.io/docs/java/latest/#asynchronous-queries)执行以下操作：

// DataStore
public class DataStore {

   private final Realm realm;

   public DataStore() {
     realm = Realm.getDefaultInstance(); // Called on the UI thread
   }

    public void getEvents(EventsLoadedListener listener) {
      RealmResults<Event> results = realm.where(Events.class).findAllAsync();
      results.addChangeListener(new RealmChangeListener() {
        public void onChange() {
          if (listener != null) {
            listener.eventsLoaded(results);
          }
        }
      });
    }

    public interface EventsLoadedListener {
      public void eventsLoaded(List<Event> events);
    }

}

// UI code
datastore.getEvents(new DataStore.EventsLoadedListener() {
    public void eventsLoaded(List<Event> events) {
      view.showEvents(events);
    }
})

使用RxJava可以大大简化上面的代码,所以我真的鼓励你研究一下. Realm还原生支持RxJava：https://realm.io/docs/java/latest/#rxjava