如何确保HealthKit数据查询代码按正确顺序执行？

你遇到的核心问题是**HKSampleQuery是异步执行的**：循环中发起的每个查询都会在后台线程处理，而你在循环结束后立刻调用了completion，此时所有查询的回调逻辑还没触发，结果字典自然是空的。要解决这个问题，需要等待所有异步查询完成后再执行completion。

下面提供两种适配不同iOS版本的实现方案：

方案1：使用DispatchGroup（兼容iOS 13及以下） #

通过DispatchGroup追踪所有异步任务的完成状态，确保所有查询结束后再返回结果：

func fetchSampleData(for types: [HKSampleType], healthStore: HKHealthStore, completion: @escaping ([HKSampleType: [HKSample]], Error?) -> Void) {
    var results = [HKSampleType: [HKSample]]()
    var encounteredError: Error?
    let group = DispatchGroup()
    
    for type in types {
        group.enter() // 标记任务开始
        let query = HKSampleQuery(
            sampleType: type,
            predicate: nil,
            limit: HKObjectQueryNoLimit,
            sortDescriptors: nil
        ) { [weak self] query, samples, error in
            defer { group.leave() } // 确保无论成功失败，都标记任务结束
            
            if let error = error {
                encounteredError = error
                return
            }
            results[type] = samples ?? []
        }
        healthStore.execute(query)
    }
    
    // 所有任务完成后调用completion
    group.notify(queue: .main) {
        completion(results, encounteredError)
    }
}

关键细节： #

• group.enter()和group.leave()必须成对出现，defer语句能保证即使查询出错，也不会遗漏leave()，避免DispatchGroup一直等待。
• notify方法指定.main队列，确保后续依赖代码（比如UI更新）在主线程执行。

方案2：使用Async/Await（iOS 15+、Swift 5.5+） #

利用Swift原生的异步编程语法，代码更简洁易读：

第一步：封装异步查询方法 #

extension HKHealthStore {
    func fetchSamples(for type: HKSampleType) async throws -> [HKSample] {
        return try await withCheckedThrowingContinuation { continuation in
            let query = HKSampleQuery(
                sampleType: type,
                predicate: nil,
                limit: HKObjectQueryNoLimit,
                sortDescriptors: nil
            ) { query, samples, error in
                if let error = error {
                    continuation.resume(throwing: error)
                } else {
                    continuation.resume(returning: samples ?? [])
                }
            }
            self.execute(query)
        }
    }
}

第二步：实现批量查询逻辑 #

func fetchSampleData(for types: [HKSampleType], healthStore: HKHealthStore) async throws -> [HKSampleType: [HKSample]] {
    var results = [HKSampleType: [HKSample]]()
    
    try await withThrowingTaskGroup(of: (HKSampleType, [HKSample]).self) { group in
        // 为每个样本类型启动异步任务
        for type in types {
            group.addTask {
                let samples = try await healthStore.fetchSamples(for: type)
                return (type, samples)
            }
        }
        
        // 收集所有任务结果
        for try await (type, samples) in group {
            results[type] = samples
        }
    }
    
    return results
}

调用方式 #

func getData() async {
    let targetTypes: [HKSampleType] = [/* 你的目标样本类型数组 */]
    let healthStore = HKHealthStore()
    
    do {
        let allResults = try await fetchSampleData(for: targetTypes, healthStore: healthStore)
        // 所有查询完成，在这里处理结果
        print(allResults)
    } catch {
        // 处理错误
        print("查询失败：\(error.localizedDescription)")
    }
}

1. 权限检查：在发起任何HealthKit查询前，必须确保已获取对应类型的读写权限，否则查询会直接失败。
2. 错误处理：两种方案都加入了错误传递逻辑，建议在实际项目中根据需求选择忽略单个错误或终止所有查询。
3. 性能优化：如果查询的样本量极大，建议设置合理的limit值，避免一次性加载过多数据导致内存压力。

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