Fixed ROOM queue count

8 months ago · e89fd07148
parent be5e283838
commit e89fd07148
1 changed files with 4 additions and 1 deletions
--- a/app/src/main/java/androidx/room/RoomTrackingLiveData.java
+++ b/app/src/main/java/androidx/room/RoomTrackingLiveData.java
@ -151,7 +151,10 @@ class RoomTrackingLiveData<T> extends LiveData<T> {
    protected void onActive() {
        super.onActive();
        mContainer.onActive(this);
-        getQueryExecutor().execute(mRefreshRunnable);
+        synchronized (lock) {
+            queued++;
+            getQueryExecutor().execute(mRefreshRunnable);
+        }
    }

    @Override