你的领域是从一根没有弯针的线打开的

Question

我以为我遵循了推荐的领域方法来运行异步数据插入，如下所示:

public void addCustomer(final Customer customer) {
        Realm insertRealm = Realm.getDefaultInstance();
        insertRealm.executeTransactionAsync(new Realm.Transaction() {
            @Override
            public void execute(Realm backgroundRealm) {
                long id = customerPrimaryKey.incrementAndGet();
                customer.setId(id);
                backgroundRealm.copyToRealm(customer);
            }
        }, new Realm.Transaction.OnSuccess() {
            @Override
            public void onSuccess() {
                Log.d(LOG_TAG, "Customer Added");
            }
        }, new Realm.Transaction.OnError() {
            @Override
            public void onError(Throwable error) {
                Log.d(LOG_TAG, error.getMessage());
            }
        });

        insertRealm.close();

    }

但是，当我运行上面的代码时，我得到“您的领域是从没有Looper的线程打开的，并且您提供了回调，我们需要一个处理程序来调用您的回调”

我在一个非活动类中运行这段代码，我在这里做错了什么，我该如何修复它。谢了。

事实证明这个查询没有问题，问题是我是从IntentService调用它的。我试图在应用程序首次运行时植入数据库，所以我像这样解决了这个问题:

protected void onHandleIntent(Intent intent) {
        Realm realm = Realm.getDefaultInstance();

        //Add sample Customers to database
        List<Customer> customers = SampleCustomerData.getCustomers();

        realm.beginTransaction();
        for (Customer customer: customers){
            customer.setId(customerPrimaryKey.getAndIncrement());
            realm.copyToRealm(customer);
        }
        realm.commitTransaction();

realm.close();

    }

该修复，在意向服务之外，从 UI 线程调用查询时工作正常。

Answer 1

您需要从UI线程调用addCustomer。

Answer 2

Realm依赖于Hanfler和Looper类的Android线程通信。看起来你从另一个后台线程查询异步操作（为什么？，它已经在后台，使用同步版本）。要解决此问题，您需要使用活动循环器的线程。使用处理程序线程作为后台线程 - 它将初始化Looper

Answer 3

为了为了

insertRealm.executeTransactionAsync(new Realm.Transaction() {
      @Override
        public void execute(Realm backgroundRealm) {
            //...
        }
    }, new Realm.Transaction.OnSuccess() {
        @Override
        public void onSuccess() {
            // !!!
        }
    }, new Realm.Transaction.OnError() {
        @Override
        public void onError(Throwable error) {
            // !!!
        }
    });

要在后台线程上调用的异步事务回调，该线程需要与循环器相关联（因此具有可以与该循环器的线程进行通信的处理程序）。

解决方案，在后台线程上使用同步事务。

但你已经明白了。

protected void onHandleIntent(Intent intent) {
    Realm realm = null;
    try {
        realm = Realm.getDefaultInstance();
        final List<Customer> customers = SampleCustomerData.getCustomers();
        realm.executeTransaction(new Realm.Transaction() {
            @Override
            public void execute(Realm realm) {
                for (Customer customer: customers){
                    customer.setId(customerPrimaryKey.getAndIncrement());
                    realm.insert(customer);
                }
            }
        });
    } finally {
        if(realm != null) {
            realm.close();
        }
    }
}