如何正确阻止代码执行直到回调

Question

我是 Unity 和 C# 的新手，并尝试查询我的 Firebase 实时数据库，但代码不会阻止回调完成。

我尝试过实现回调，但这似乎不起作用。

static public void ReadFromDb(int level, Action<int> callback) 
{
    int return_value = -1;
    string sessionId = PlayerPrefs.GetString("SessionID");

    FirebaseDatabase.DefaultInstance.GetReference("users/"+sessionId).GetValueAsync().ContinueWith(task => {
        if (task.IsFaulted) 
        {
            // Handle the error...
            Debug.Log("Task faulted");
            callback(return_value);
        } 
        else if (task.IsCompleted) 
        {
            DataSnapshot snapshot = task.Result;
            string score_string = (snapshot.Child(level.ToString()).Value).ToString();
            Debug.Log("score_string " + score_string);
            return_value = int.Parse(score_string);
            callback(return_value);
        }
    });
}


public void LevelComplete() 
{
    DatabaseCode.writeDatabase(SceneManager.GetActiveScene().buildIndex + 1, counter);
    DatabaseCode.ReadFromDb(SceneManager.GetActiveScene().buildIndex + 1, (result) => {
        prevlevelscore = result;
        Debug.Log("result " + result.ToString());
    });
    prevscore = prevlevelscore;
    Debug.Log("Returned value: " + prevlevelscore.ToString());
    SceneManager.LoadScene(SceneManager.GetActiveScene().buildIndex + 1);
}

在LevelComplete() 中，Debug.Log("Returned value: " + prevlevelscore.ToString()); 在prevlevelscore = result; 之前执行
我想确保在执行Debug.Log 之前更新prevlevelscore 的值。

Answer 1

将其余代码也放入回调中：

public void LevelComplete() 
{
    DatabaseCode.writeDatabase(SceneManager.GetActiveScene().buildIndex + 1, counter);
    DatabaseCode.ReadFromDb(SceneManager.GetActiveScene().buildIndex + 1, (result) => {
        Debug.Log("result " + result.ToString());
        prevscore = result;
        SceneManager.LoadScene(SceneManager.GetActiveScene().buildIndex + 1);
    });    
}

Answer 2

您的问题是您的 ReadFromDb 方法在完成之前返回。您可以通过将所有代码放入回调中来解决此问题（但您不能一直这样做），或者您可以使用异步等待模式。

使 ReadFromDb 异步：

    static public async Task ReadFromDb(int level, Action<int> callback) 
    {
        int return_value = -1;
        string sessionId = PlayerPrefs.GetString("SessionID");

        await FirebaseDatabase.DefaultInstance.GetReference("users/"+sessionId).GetValueAsync().ContinueWith(task => {
            if (task.IsFaulted) 
            {
                // Handle the error...
                Debug.Log("Task faulted");
                callback(return_value);
            } 
            else if (task.IsCompleted) 
            {
                DataSnapshot snapshot = task.Result;
                string score_string = (snapshot.Child(level.ToString()).Value).ToString();
                Debug.Log("score_string " + score_string);
                return_value = int.Parse(score_string);
                callback(return_value);
            }
        });
    }

请注意 GetValueAsync().ContinueWith 之前的 await 键，因为此精确代码是异步的，如果您想在获取结果之前保持代码执行，则需要等待。

在你的来电者中：

    public async Task LevelComplete() 
    {
        DatabaseCode.writeDatabase(SceneManager.GetActiveScene().buildIndex + 1, counter);
        await DatabaseCode.ReadFromDb(SceneManager.GetActiveScene().buildIndex + 1, (result) => {
            prevlevelscore = result;
            Debug.Log("result " + result.ToString());
        });
        prevscore = prevlevelscore;
        Debug.Log("Returned value: " + prevlevelscore.ToString());
        SceneManager.LoadScene(SceneManager.GetActiveScene().buildIndex + 1);
    }

这个方法也变成异步的（因为异步传播）。同样， await 关键字将一直执行，直到 readFromDb 方法完成。这意味着您的数据将准备就绪。