如何使用Dispatch Group等待调用依赖不同数据的多个函数？

看起来你已经找对方向了——用Dispatch Group来协调多个异步任务，确保后续处理逻辑等所有数据更新完成再执行，这个思路完全靠谱！我帮你补全代码并拆解关键细节，让整个逻辑更完整清晰：

完整实现代码 #

下面是包含异步更新、Dispatch Group调度和处理函数调用的完整示例：

// 数据定义
var a: String?
var b: String?
var c: String?

// 模拟异步更新函数（替换成你实际的网络请求/本地数据加载逻辑）
func updateA(completion: @escaping () -> Void) {
    DispatchQueue.global().asyncAfter(deadline: .now() + 1) {
        self.a = "Updated A"
        completion()
    }
}

func updateB(completion: @escaping () -> Void) {
    DispatchQueue.global().asyncAfter(deadline: .now() + 0.5) {
        self.b = "Updated B"
        completion()
    }
}

func updateC(completion: @escaping () -> Void) {
    DispatchQueue.global().asyncAfter(deadline: .now() + 1.5) {
        self.c = "Updated C"
        completion()
    }
}

// 模拟处理函数（仅使用部分数据的业务逻辑）
func processUsingA() {
    guard let a = a else { return }
    print("Processing with A: \(a)")
}

func processUsingBAndC() {
    guard let b = b, let c = c else { return }
    print("Processing with B & C: \(b), \(c)")
}

func processUsingAllData() {
    guard let a = a, let b = b, let c = c else { return }
    print("Processing with all data: \(a), \(b), \(c)")
}

// 核心：用Dispatch Group协调异步任务
let group = DispatchGroup()

// 为每个异步任务标记进入组
group.enter()
updateA {
    // 任务完成后标记离开组
    group.leave()
}

group.enter()
updateB {
    group.leave()
}

group.enter()
updateC {
    group.leave()
}

// 所有异步任务完成后，触发后续处理逻辑
group.notify(queue: .main) {
    // 这里可以安全调用所有依赖a、b、c的处理函数
    self.processUsingA()
    self.processUsingBAndC()
    self.processUsingAllData()
}

关键细节拆解 #

• 严格匹配enter与leave：每个异步任务开始前调用group.enter()，任务完成（无论成功/失败）的闭包里必须调用group.leave()，否则Dispatch Group会一直处于等待状态，notify的逻辑永远不会执行。
• notify队列的选择：如果你的处理函数涉及UI操作，必须指定queue: .main；如果是纯后台计算任务，可以用DispatchQueue.global()提升效率。
• 线程安全注意：如果a、b、c可能被多个线程读写，建议用串行队列或者锁来保护变量，避免数据竞争问题。
• 错误处理补充：如果你的update函数有错误分支，一定要在错误回调里也调用completion()（也就是触发group.leave()），比如：

  func updateA(completion: @escaping (Error?) -> Void) {
      DispatchQueue.global().async {
          if let error = someNetworkRequest() {
              completion(error)
          } else {
              self.a = "Updated A"
              completion(nil)
          }
      }
  }
  
  // 调用时
  group.enter()
  updateA { error in
      // 这里可以处理错误
      group.leave()
  }
  

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