在另一个线程上运行 Firebase 回调会阻塞 UI

Question

我知道这个问题可能看起来是重复的，我已经阅读了十个关于同一件事的其他帖子，但我找不到问题

我的活动中有这个方法：

public void saveResponse(final Response studentResponse, final Content content)
    fb.getReference("...").addListenerForSingleValueEvent(new ValueEventListener() {
        @Override
        public void onDataChange(final DataSnapshot dataSnapshot) {

           new Thread(new Runnable() {
               @Override
               public void run() {
                    Map<String, Object> responseMap = new HashMap<>();
                    responseMap.put("end_date", studentResponse.end_date);
                    responseMap.put("start_date", studentResponse.start_date);
                    responseMap.put("time", studentResponse.time);
                    responseMap.put("points", studentResponse.points);
                    responseMap.put("max_points", studentResponse.max_points);
                    responseMap.put("selected_options", studentResponse.selected_options);
                    if (!TextUtils.isEmpty(studentResponse.free_text))
                        responseMap.put("free_text", studentResponse.free_text);

                    DataSnapshot contentRef = dataSnapshot.child("/sections/" + currentSection + "/sections/" + currentSubsection + "/contents/" + content.id);
                    final int oldPoints = contentRef.hasChild("points") ? contentRef.child("points").getValue(int.class) : 0;
                    contentRef.getRef().setValue(responseMap);
                    contentRef.getRef().setPriority(ServerValue.TIMESTAMP);

                    DataSnapshot subSectionRef = dataSnapshot.child("/sections/" + currentSection + "/sections/" + currentSubsection);
                    long subSectionPoints = (subSectionRef.hasChild("points") ? subSectionRef.child("points").getValue(long.class) : 0) + studentResponse.points - oldPoints;
                    subSectionRef.child("points").getRef().setValue(subSectionPoints);

                    int indexOf = currentContents.indexOf(content) + 1;
                    if(indexOf > 0 && indexOf < currentContents.size()) {
                        CourseContent content = currentContents.get(indexOf);
                        subSectionRef.child("currentPosition").getRef().setValue(content.order);
                    }

                    DataSnapshot sectionRef = dataSnapshot.child("/sections/" + currentSection);
                    long sectionPoints = (sectionRef.hasChild("points") ? sectionRef.child("points").getValue(long.class) : 0) + studentResponse.points - oldPoints;
                    sectionRef.child("points").getRef().setValue(sectionPoints);

                    long coursePoints = (dataSnapshot.hasChild("points") ? dataSnapshot.child("points").getValue(long.class) : 0) + studentResponse.points - oldPoints;
                    dataSnapshot.child("points").getRef().setValue(coursePoints);
                    dataSnapshot.getRef().setPriority(MAX_SAFE_INTEGER - coursePoints);

                    int completed = 0;
                    for (DataSnapshot sect : dataSnapshot.child("sections").getChildren()) {
                        for (DataSnapshot subSect : sect.child("sections").getChildren()) {
                            int currPos = subSect.hasChild("currentPosition") ? subSect.child("currentPosition").getValue(int.class) : 0;
                            completed += currPos;
                        }
                    }

                    double progress = totalContents > 0 ? (double) completed / (double) totalContents : 0;
                    dataSnapshot.child("progress").getRef().setValue(progress);
               }
           }.start();
        }
        ...
    });
}

在单击处理程序中，我调用此方法，然后更改片段（使用自定义动画）。

问题是，片段过渡并不平滑，它会冻结一点，如果我在可运行文件中注释所有内容，那么它会运行顺利。我也尝试过使用 AsyncTask 并且发生了同样的情况。

在 runnable 内部，我只是查询 dataSnapshot 及其子项，并设置一些值 (dataSnapshot.child("item").getRef().setValue(x))

另外一个奇怪的地方是，如果我在run()里面放了一个断点，它也能顺利运行。

Answer 1

我认为问题出在你方法的逻辑上。

监听器 onDataChange() 处于活动状态，它将响应数据的任何更改。我的意思是，如果您在 onDataChange() 方法中更改数据，则每次使用 (dataSnapshot.child("item").getRef().setValue(x))) 设置值时都会调用它，因此，它类似于在不退出的情况下进行“递归”调用。

为了解决这个问题，你应该在点击事件中获取你想要改变的键，然后使用

mDatabase = FirebaseDatabase.getInstance().getReference(); mDatabase.child("key").child("item").setValue(x);

查看https://firebase.google.com/docs/database/android/read-and-write了解更多信息

Answer 2

衍生线程继承创建它的线程的优先级。尝试降低工作线程的优先级以防止它与 UI 线程竞争：

@Override
public void onDataChange(final DataSnapshot dataSnapshot) {
    new Thread(new Runnable() {
        @Override
        public void run() {
            Process.setThreadPriority(Process.THREAD_PRIORITY_BACKGROUND);
            ...
        }).start();

Answer 3

每次调用 onDataChange 方法都会创建一个新线程，奇怪的是：“如果我在 run() 中放置断点，它也可以顺利运行。” 可能是您应该检查是否创建了太多线程。