Apple HealthKit的HK系列查询是否异步运行？需显式开线程吗？

核心问题解答 #

• HKStatisticsQuery、HKSampleQuery、HKStatisticsCollectionQuery 这类查询本身就是异步运行的，不需要你显式将它们放入单独线程执行。
• 当你调用 healthStore.execute(_:) 时，HealthKit 框架会自动在后台线程处理查询逻辑，完成后通过你传入的 resultsHandler 闭包返回结果，这个闭包默认在后台线程执行。

你的代码无需额外异步块 #

你当前的写法是正确的，不需要将查询逻辑包裹在异步块中。不过可以针对几个细节做优化：

原代码 #

private func readOxygrnSaturation(){
        dispatchGroup.enter()
        let quantityType  = HKObjectType.quantityType(forIdentifier: .oxygenSaturation)!
        let sampleQuery = HKSampleQuery.init(sampleType: quantityType,
                                             predicate: nil,
                                             limit: HKObjectQueryNoLimit,
                                             sortDescriptors: nil,
                                             resultsHandler: { (query, results, error) in
            
            guard let samples = results as? [HKQuantitySample] else {
                print(error!)
                return
            }
            for sample in samples {
                let mSample = sample.quantity.doubleValue(for: HKUnit(from: "%"))
                self.oxygenSaturation.append(HealthData(unit: "%", startDate: self.dateFormatter.string(from: sample.startDate) , endDate: self.dateFormatter.string(from: sample.endDate), value: mSample))
            }
            self.dispatchGroup.leave()
        })
        self.healthStore .execute(sampleQuery)
        
    }

优化建议 #

1. 避免循环引用：在闭包中使用 [weak self] 捕获弱引用，防止内存泄漏
2. 安全处理错误：不要强制解包 error，先判断是否存在再处理
3. 线程安全（若后续更新UI）：如果需要在结果处理后更新UI，必须切回主线程

优化后的代码示例：

private func readOxygenSaturation(){
    dispatchGroup.enter()
    guard let quantityType = HKObjectType.quantityType(forIdentifier: .oxygenSaturation) else {
        print("无法获取血氧饱和度类型")
        dispatchGroup.leave()
        return
    }
    
    let sampleQuery = HKSampleQuery(sampleType: quantityType,
                                    predicate: nil,
                                    limit: HKObjectQueryNoLimit,
                                    sortDescriptors: nil,
                                    resultsHandler: { [weak self] (query, results, error) in
        defer {
            self?.dispatchGroup.leave()
        }
        
        if let error = error {
            print("查询血氧数据失败：\(error.localizedDescription)")
            return
        }
        
        guard let samples = results as? [HKQuantitySample], let self = self else {
            print("无有效血氧数据或对象已释放")
            return
        }
        
        for sample in samples {
            let mSample = sample.quantity.doubleValue(for: HKUnit(from: "%"))
            let healthData = HealthData(unit: "%",
                                       startDate: self.dateFormatter.string(from: sample.startDate),
                                       endDate: self.dateFormatter.string(from: sample.endDate),
                                       value: mSample)
            self.oxygenSaturation.append(healthData)
        }
        
        // 若需更新UI，切回主线程
        DispatchQueue.main.async {
            // 比如刷新表格、更新UI组件
        }
    })
    healthStore.execute(sampleQuery)
}

关键注意点 #

• resultsHandler 运行在后台线程，所以如果在其中执行UI操作，必须通过 DispatchQueue.main.async 切换到主线程。
• 处理共享数据（比如你的 oxygenSaturation 数组）时，要确保线程安全，如果有多个线程同时修改，建议加锁或者用串行队列处理。

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