Firebase技术问题：如何等待多个数据库查询全部完成？

这个场景在Firebase开发里特别常见——当你有多个数据库引用需要异步拉取数据，而且必须等所有数据都收集完毕后才能进行下一步处理时，DispatchGroup是最靠谱的解决方案，它能帮你精准追踪所有异步任务的完成状态。

具体实现思路 #

1. 先创建一个DispatchGroup实例，用来管理所有异步请求的生命周期
2. 准备一个数组统一存储所有收集到的Post数据
3. 遍历每个引用时，调用group.enter()标记一个任务启动
4. 在Firebase的回调闭包里处理数据，完成后调用group.leave()标记任务结束
5. 通过group.notify监听所有任务完成事件，在这个闭包里执行后续的数据处理逻辑

完整代码示例 #

// 1. 初始化调度组和数据存储数组
let dataFetchGroup = DispatchGroup()
var collectedPosts: [Post] = []

// 2. 遍历所有Firebase引用
for ref in baseRefs {
    dataFetchGroup.enter() // 标记当前异步任务开始
    
    ref.queryOrdered(byChild: "datetime")
       .queryLimited(toFirst: 4)
       .observeSingleEvent(of: .value, with: { (postSnapshot) in
           // 解析当前引用返回的数据
           for child in postSnapshot.children {
               guard let postRef = child as? DataSnapshot,
                     let postData = postRef.value as? [String: AnyObject] else {
                   dataFetchGroup.leave() // 解析失败也要标记任务结束
                   return
               }
               // 初始化Post对象（补全你自己的初始化参数）
               let newPost = Post(key: postRef.key, data: postData)
               collectedPosts.append(newPost)
           }
           
           dataFetchGroup.leave() // 当前引用的任务处理完成
       }) { (error) in
           // 处理请求失败的情况
           print("数据拉取失败: \(error.localizedDescription)")
           dataFetchGroup.leave() // 错误场景下必须调用leave，避免组永远等待
       }
}

// 3. 所有任务完成后执行后续操作
dataFetchGroup.notify(queue: .main) {
    print("所有数据收集完成！共获取到\(collectedPosts.count)条Post数据")
    // 在这里编写你的下一步逻辑：比如刷新UI、数据聚合、存储到本地等
}

关键细节提醒 #

• enter()和leave()必须配对：每个启动的任务都要标记结束，哪怕是请求失败或者数据解析出错的情况，否则notify永远不会触发，还可能引发内存泄漏。
• 队列选择：notify用.main队列是因为后续处理通常涉及UI更新，如果只是后台数据运算，可以改用全局队列比如.global()。
• 线程安全：Firebase的回调默认在后台线程执行，但因为enter/leave确保了所有数据修改都在notify之前完成，而notify在主线程执行，所以这里的数组操作不会有线程冲突问题。如果你的场景更复杂，可以考虑加串行队列或者线程锁来保护数据。

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