领域数据同步不一致

我遇到一个问题，每次执行相同的查询时，Realm 有时会返回不同的数据。目前我正在使用 SyncAdapter 进行上传。我们的想法是尝试实现离线模式。

因此，当用户创建一个项目时，它会被添加到领域数据库中。我通过获取 maxId 并向其添加 1000 来手动生成该项目的 ID。之后，我将 itemID 发送到 UploadSyncAdapter，在其中获取 itemById 并将其发送到后端，后端返回具有真实 ID 的项目。因此，之后我删除旧项目并将新项目插入领域。

在我返回并读取数据后，它每秒返回一个大小为 115 数据的数组，另一次返回一个大小为 116 的数组。我什至使用调试器通过 ID 搜索该项目，它确实一次找到了该项目，第二次却没有。但看起来在我重建项目后，该项目就在那里并且可以正常工作，或者如果我使用即时运行重新运行应用程序。

任何帮助表示赞赏...

UPDATE顺便说一句，我正在使用 RXjava 从服务器获取数据，但它正在当前线程（SyncAdapter 线程）上订阅和观察。

这是代码：

@Override
public void onNext(TaskResponse taskResponse) {
     tasksDatabaseManager.deleteTaskById(taskId);
     List<Task> tasks = taskResponse.getTaskDataList();
     tasksDatabaseManager.insertTasks(tasks);
 }

public void deleteTaskById(int taskId){
    Realm realm = Realm.getDefaultInstance();
    realm.beginTransaction();
    RealmResults<Task> rows = realm.where(Task.class).equalTo(ID, taskId).findAll();
    rows.deleteAllFromRealm();
    realm.commitTransaction();
    realm.close();
}

private void copyOrUpdateTasks(List<Task> tasksList){
    Realm realm = Realm.getDefaultInstance();
    ArrayList<Task> updatedTaskList;
    //first initialize task permissions
    updatedTaskList = filterTasksByPermission(tasksList);
    //initialize custom task data
    for (Task task : updatedTaskList) {
        initializeTaskCustomFields(task);
    }
    //save new data
    Log.d(TAG, "tasks number before update: " + getTasks().size());
    realm.beginTransaction();
    realm.copyToRealmOrUpdate(updatedTaskList);
    realm.commitTransaction();
    realm.close();

    Log.d(TAG, "tasks number after update: " + getTasks().size());
}

在 filterTasksByPermission 中，我只是计算任务的一些权限，但任务正在列表中返回。在initializeTaskCustomFields中，我也只是在保存到Realm之前计算对象的2个字段（这样我也将这些值保存在Realm中）

经过一番研究，我发现了问题所在。但如果我错了，请纠正我。我在 Rx 调用中将 Subscribers.io() 替换为 Subscribers.newThread()，现在它工作正常。所以我的理论是：

在调用我的 UploadAdapter 上传更改的数据之前，我使用带有 Subscribers.io() 的 Rx 调用将我的项目插入数据库中。 Subscribers.io() 使用线程池来重用线程，或者在必要时创建新线程。假设它生成了一个名为“A”的线程。线程 A 获取一个 Realm 实例（假设 Realm 快照为“1”）并将创建的项目插入其中。在调用 SyncAdapter 后，它还会获得一个具有相同 Realm 快照“1”的新 Realm 实例。 SyncAdapter 完成将数据上传到服务器后，它会删除旧项目，并插入从服务器获取的新项目。因此，在此 Realm 数据发生更改后，最新的 Realm 快照现在为“2”。 SyncAdapter 向 Activity 发送广播，表明上传已完成，并且应该从 Realm 数据库获取新数据。

为了从 Realm 读取数据，我还使用 Rx 和 Subscribers.io()。因此，当从 Realm 请求新数据时，Subscribers.io() 的池中已经有一个线程正在等待重用，这就是线程“A”。而且由于这个线程是一个非Looper线程，它不知道Realm数据发生了变化，并且它仍然使用Realm快照“1”，所以这就是我从Realm获取旧数据的原因。刷新几次后 Subscribers.io() 可能会创建一个新线程，假设线程“B”。

所以线程“B”也得到了一个领域快照，这次它是最新的快照，所以快照“2”。它返回正确的数据。

因此，当使用 Subscribers.newThread() 时，它始终会创建一个新线程，并且始终具有最新的 Realm 快照。

以下是有关 Subscribers.io() 和 Subscribers.newThread() 之间差异的链接：使用 Rxjava Schedulers.newThread() 与 Schedulers.io() 进行改造

希望这对某人有帮助！