Swift DispatchSemaphore 正在冻结应用程序

Question

我尝试使用 DispatchSemaphore 在循环中运行 API 服务，它冻结了应用程序， 我的要求是我已经调用 API 来获取详细信息列表每个详细信息我有不同的请求，我需要在循环中调用 API，每个 API 都依赖于先前 API 的响应，因此我使用了 DispatchSemaphore 等待和信号方法，但它正在释放应用程序

示例代码：

func DownloadInformation(urlString: String, device: String, indexValue: Int, completion: @escaping (_ requestIndex: Int?) -> (Void)) {
        ApiService.sharedInstance.DownloadHealthInsightDetails(ID: self.equipmentAnalaysisArr[indexValue].id) { [self] (serverResponse, error, cardID) -> (Void) in
            if(serverResponse != nil && error == nil) {
                let insightCycleList = serverResponse as? NSDictionary
                if (insightCycleList?["error"]) == nil {
                                                            
                    if let cycle = insightCycleList?["cycles"] as? [AnyObject], cycle.count != 0 {
                        let dispatchGroup = DispatchGroup()
                        let dispatchQueue = DispatchQueue(label: "taskQueue")
                        let dispatchSemaphore = DispatchSemaphore(value: 0)
                            for i in 0..<cycle.count {
                                if i < 5 {
                                    dispatchGroup.enter()
                                    let element = cycle[i]
                                                                            
                                        self.DownloadCycleData(urlString: blob_url , cycleDownloadCompletion: {_ in
                                            completion(indexValue)
                                            dispatchSemaphore.signal()
                                            dispatchGroup.leave()
                                        })
                                    dispatchSemaphore.wait()
                                }
                            }
                            
                        dispatchGroup.notify(queue: DispatchQueue.main) {
                                print("done")
                            }
//                        }
                    } else {
                        self.ShowMessage(index: indexValue, message: self.message)
                    }
                }else {
                    self.ShowMessage(index: indexValue, message: self.message)
                }
            }
        }
    }

谁能给我建议来解决这个问题？

谢谢。

Answer 1

您没有使用 DispatchQueue(label: "taskQueue")。 但也许你应该考虑在这种情况下使用一些状态机。

if let cycle = insightCycleList?["cycles"] as? [AnyObject], cycle.count != 0 {
    let dispatchQueue = DispatchQueue(label: "taskQueue")
    let semaphore = DispatchSemaphore(value: 0)
    dispatchQueue.async {
        for i in 0..<cycle.count {
            if i < 5 {
                let cycleSemaphore = DispatchSemaphore(value: 0)
                let element = cycle[i]
                self.DownloadCycleData(urlString: blob_url , cycleDownloadCompletion: {_ in
                    completion(indexValue)
                    cycleSemaphore.signal()
                })
                cycleSemaphore.wait()
            }
        }
        semaphore.signal()
    }
    semaphore.wait()
}