时间戳

首页 > 解决方案 > Firebase 和 Swift：异步调用、完成处理程序

ios - Firebase 和 Swift：异步调用、完成处理程序

问题描述

我已经阅读了很多关于这个主题的内容，但仍然对这个特定问题感到困惑。我有许多相互依赖的 Firebase 调用。这是我的代码的一种简化示例。我很难让它更短，但仍然能理解重点：

class ScoreUpdater {

static let ref = Database.database().reference()

var userAranking = Int?
var userBranking = Int?
var rankingAreceived = false
var rankingBreceived = false
var sum = 0

// Pass in the current user and the current meme 
static func beginUpdate(memeID: String, userID: String) {

    // Iterate through each user who has ranked the meme before
    ScoreUpdater.ref.child("memes/\(memeID)/rankings")observeSingleEvent(of: .value) {

        let enumerator = snapshot.children
        while let nextUser = enumerator.nextObject() as? DataSnapshot {

            // Create a currentUpdater instance for the current user paired with each other user
            let currentUpdater = ScoreUpdater()

这是异步调用开始的地方。多个gatherRankingValues 函数可以同时运行。这个函数包含一个异步的 Firebase 调用，这对于这个函数是可以的。然而，在 collectRankingValues 完成之前，updateScores 无法运行。这就是为什么我有完成处理程序。根据我的调试打印，我认为这个区域还可以。

            // After gatherRankingValues is finished running,
            // then updateScores can run
            currentUpdater.gatherRankingValues(userA: userID, userB: nextUser.key as! String) {
                currentUpdater, userA, userB in
                currentUpdater.updateScores(userA: userA, userB:userB)
            }

        }

    }

}

func gatherRankingValues(userA: String, userB: String, completion: @escaping (_ currentUpdater: SimilarityScoreUpdater, _ userA: String, _ userB: String) -> Void) {

    // Iterate through every meme in the database
    ScoreUpdater.ref.child("memes").observeSingleEvent(of: .value) {

        snapshot in
        let enumerator = snapshot.children

        while let nextMeme = enumerator.nextObject() as? DataSnapshot {

这是主要问题所在。 self.getRankingA 和 self.getRankingB 永远不会运行。这两种方法都需要在计算方法之前运行。我尝试放入“whilerankingReceived == false”循环以防止计算开始。当从数据库接收到值时，我使用完成处理程序在 self.rankingAreceived 和 self.rankingBreceived 中进行通知。相反，计算永远不会发生，循环变得无限。

如果我删除等待接收排名的 while 循环，则计算将“执行”，但最终结果最终为零，因为 getRankingA 和 getRankingB 方法仍然没有被调用。


            self.getRankingA(userA: userA, memeID: nextMeme.key) {
                self.rankingAreceived = true
            }

            self.getRankingB(userB: userB, memeID: nextMeme.key) {
                self.rankingBreceived = true
            }

            while self.rankingAreceived == false || self.rankingBreceived == false {
                continue
            }

            self.calculation()

        }

所以是的，在完成被调用之前，每个模因都会循环播放，但不会调用排名。我不知道如何让循环等待 getRankingA 和 getRankingB 的排名以及计算方法在继续下一个 meme 之前运行。我需要在循环通过所有模因之后调用gatherRankingValues（见下文），但在再次调用循环之前完成每个排名和计算......我如何在getRankingA和getRankingB完成处理程序中告诉模因迭代循环等待？

        // After every meme has been looped through for this pair of users, call completion
        completion(self, userA, userB)

    }

}

function getRankingA(userA: String, memeID: String, completion: @escaping () -> Void) {

    ScoreUpdater.ref.child("memes/\(memeID)\rankings\(userA)").observeSingleEvent(of: .value) {
        snapshot in
        self.userAranking = snapshot.value
        completion()

    }
}

function getRankingB(userB: String, memeID: String, completion: @escaping () -> Void) {

    ScoreUpdater.ref.child("memes/\(memeID)\rankings\(userB)").observeSingleEvent(of: .value) {
        snapshot in
        self.userBranking = snapshot.value
        completion()

    }
}

func calculation() {
    self.sum = self.userAranking + self.userBranking
    self.userAranking = nil
    self.userBranking = nil
}

func updateScores() {
    ScoreUpdater.ref.child(...)...setValue(self.sum)
}

}

标签： iosswiftfirebaseasynchronouscompletionhandler

解决方案

要等待循环完成或更好，请在执行一些异步调用后执行操作，您可以使用 DispatchGroups。这个例子展示了它们是如何工作的：

let group = DispatchGroup()

var isExecutedOne = false
var isExecutedTwo = false

group.enter()
myAsyncCallOne() {
    isExecutedOne = true
    group.leave()
}

group.enter()
myAsyncCallTwo() {
    isExecutedOTwo = true
    group.leave()
}

group.notify(queue: .main) {
    if isExecutedOne && isExecutedTwo {
        print("hooray!")
    } else {
        print("nope...")
    }
}

更新

此示例向您展示了如何使用组来控制输出。没有必要 wait() 什么的。您只需在循环的每次迭代中输入组，将其留在异步回调中，当每个任务离开组时，group.notify()都会被调用，您可以进行计算：

while let nextMeme = enumerator.nextObject() as? DataSnapshot {
    let group = DispatchGroup()

    group.enter()
    self.getRankingA(userA: userA, memeID: nextMeme.key) {
        self.rankingAreceived = true
        group.leave()
    }

    group.enter()
    self.getRankingB(userB: userB, memeID: nextMeme.key) {
        self.rankingBreceived = true
        group.leave()
    }

    // is called when the last task left the group
    group.notify(queue: .main) {
        self.calculation()
    }

}

group.notify()当所有呼叫离开组时被呼叫。您也可以拥有嵌套组。

快乐编码！

推荐阅读