如何使用循环器创建后台线程

有人可以分享带有 Looper 的后台线程的实现吗，我可以将其传递给 subscribeOn(AndroidScheduler.from(/背景线程与循环/)).

我需要这个，因为我正在尝试实现一个 DBService 类，该类在后台运行其所有操作，同时仍然获取实时对象更新。因此，当我应用 addChangeListener 时，会引发异常：

java.lang.IllegalStateException: Your Realm is opened from a thread without a Looper. Async queries need a Handler to send results of your query

或者如果我使用 findAll() 而不是 findAllAsync()：

java.lang.IllegalStateException: You can't register a listener from a non-Looper thread or IntentService thread.

数据库服务代码：

public Observable<List> getAll(Class clazz) {
    return Observable.defer(() -> {
        Realm realm = Realm.getDefaultInstance();
        return realm.where(clazz).findAll().asObservable()
                .map(o -> realm.copyFromRealm((RealmResults) o))
                .doOnUnsubscribe(() -> closeRealm(realm))
                .doOnTerminate(() -> closeRealm(realm));
    });
}

HandlerThread 完成这项工作。

HandlerThread handlerThread = new HandlerThread("backgroundThread");
if (!handlerThread.isAlive())
    handlerThread.start();
AndroidSchedulers.from(handlerThread.getLooper());