Firebase OnSuccessListener等待完成时超时问题及解决咨询

你用while循环等待Firestore回调的思路行不通，核心原因是Android主线程是单线程模型：你的while循环在主线程里持续占用CPU，导致OnSuccessListener的回调（默认在主线程执行）完全没机会运行，不仅cont永远不会变为true，还会触发应用无响应（ANR）。

要解决returnData因加载不及时为空的问题，你需要遵循异步编程的逻辑，让数据加载完成后主动通知后续操作，而不是阻塞线程等待。下面是两种适合Java项目的可行方案：

方案一：自定义回调接口 #

先定义一个回调接口，用来传递加载结果：

public interface OnFragmentDataLoadedListener {
    void onDataLoaded(FragmentData data);
    void onLoadFailed(Exception e);
}

修改你的getFragData方法，不再直接返回数据，而是通过回调传递结果：

public void getFragData(String fragType, OnFragmentDataLoadedListener listener) {
    Log.d("useremail", currentUser.getEmail());
    DocumentReference docRef = db.collection("users")
            .document(currentUser.getEmail())
            .collection("FragmentData")
            .document(fragType);
    
    docRef.get()
            .addOnSuccessListener(documentSnapshot -> {
                FragmentData data = documentSnapshot.toObject(FragmentData.class);
                listener.onDataLoaded(data);
            })
            .addOnFailureListener(e -> {
                listener.onLoadFailed(e);
            });
}

调用时通过回调处理加载完成的数据：

getFragData("你的fragType值", new OnFragmentDataLoadedListener() {
    @Override
    public void onDataLoaded(FragmentData data) {
        // 这里拿到加载完成的数据，执行后续逻辑
        Log.d("testhi", "" + data.getId().get(0));
    }

    @Override
    public void onLoadFailed(Exception e) {
        // 处理数据加载失败的情况
        Log.e("Firestore错误", "加载FragmentData失败", e);
    }
});

方案二：使用LiveData（适用于Jetpack项目） #

如果你的项目用了Android Jetpack，可以用LiveData来观察数据加载状态：

import androidx.lifecycle.MutableLiveData;

public MutableLiveData<FragmentData> getFragData(String fragType) {
    MutableLiveData<FragmentData> dataLiveData = new MutableLiveData<>();
    
    Log.d("useremail", currentUser.getEmail());
    DocumentReference docRef = db.collection("users")
            .document(currentUser.getEmail())
            .collection("FragmentData")
            .document(fragType);
    
    docRef.get()
            .addOnSuccessListener(documentSnapshot -> {
                FragmentData data = documentSnapshot.toObject(FragmentData.class);
                dataLiveData.postValue(data);
            })
            .addOnFailureListener(e -> {
                // 加载失败时可以传递null或自定义错误状态
                dataLiveData.postValue(null);
                Log.e("Firestore错误", "加载失败", e);
            });
    
    return dataLiveData;
}

调用时观察LiveData的变化：

getFragData("你的fragType值").observe(this, data -> {
    if (data != null) {
        // 数据加载完成，执行操作
        Log.d("testhi", "" + data.getId().get(0));
    }
});

关键提醒 #

永远不要在主线程用循环等待异步操作，这完全违背了异步编程的设计初衷，只会导致线程阻塞和应用卡顿。正确的做法是让异步任务完成后主动通知你，再执行后续逻辑。

内容的提问来源于stack exchange，提问作者Chewietheshiba