信号量同步请求 Swift4 永远停止

Question

我需要来自Web服务的同步请求，所以我使用sempahore：

class func syncProducts() {
print("syncProducts() 1")
let idsLocal = getProductsIds()
let semaphore = DispatchSemaphore(value: 0)
var idsCloud : [Int] = []
print("Getting cloud ids... 1")
OdooService.getProductsIds { (params: [Int]) in
print("SuccessBlock size ids: (params.count)  1")
idsCloud = params
semaphore.signal()
}
semaphore.wait()
print("Depois do GetproductsIds:  1")
}

但在此示例中，应用程序将永远保持锁定！请求永远不会结束。这是我从网络服务器请求数据并在情况的情况下返回成功块的函数。

static func getProductsIds(successBlock: @escaping (_ params: [Int]) -> Void)  {
// check odoo auth
let dispatch = DispatchGroup()
if( OdooAuth.uid == 0 ) {
print("Odoo offline, tentando reconectar...")
dispatch.enter()
OdooAuth.reconnect(successBlock: { params in
print("Reconectado com sucesso...")
dispatch.leave()
}, failureBlock: { params in
print("Falha no ReAuth")
return
})
}
print("Start request from Odoo...")
let fieldsProducts = ["id"]
let options = [ "fields": fieldsProducts] as [String : Any]
var idsList : [Int] = []
let params = [OdooAuth.db, OdooAuth.uid, OdooAuth.password,"product.template","search_read",[],options] as [Any]
AlamofireXMLRPC.request(OdooAuth.host2, methodName: "execute_kw", parameters: params).responseXMLRPC {
(response: DataResponse<XMLRPCNode>) -> Void in
switch response.result {
case .success( _):
print("Success to get Ids")
let str = String(data: response.data!, encoding: String.Encoding.utf8) as String!
let options = AEXMLOptions()
let xmlDoc = try? AEXMLDocument(xml: (str?.data(using: .utf8))!,options: options)
//print(xmlDoc!.xml)
for child in (xmlDoc?.root["params"]["param"]["value"]["array"]["data"].children)! {
for childValue in child["struct"].children {
let id = childValue["value"]["int"].value!
idsList.append(Int(id)!)
//print("Id: (id)")
}
}
successBlock(idsList)
break
case .failure(let error):
print("Error to get Ids: (error.localizedDescription)")
break
} // fim switch
} // fim request
} // fim getProductsIds

我不知道信号量是否是执行此操作的最佳方法，但我需要同步请求！我尝试像在reauth中使用DispatchGroup()，但不起作用。

Answer 1

我希望死锁是在主线程上调用回调的结果getProductsIds主线程被信号量阻止。据我所知，默认情况下，Alamofire在主线程上调度回调，我希望AlamofireXMLRPC就是这种情况，因为它是Alamofire的包装器。

我强烈建议在异步操作期间不要阻塞主线程。

但是，如果出于任何真正好的理由你不能这样做，你将需要确保回调不会在主调度队列上被调度(因为那个回调被阻止等待信号)。Alamofire本身有一个response重载，允许指定运行回调的DispatchQueue对象。似乎AlamofireXMLRPC也有一个，所以我会尝试利用它并改变

AlamofireXMLRPC.request(OdooAuth.host2, methodName: "execute_kw", parameters: params)
.responseXMLRPC {
// process result
}

自：

AlamofireXMLRPC.request(OdooAuth.host2, methodName: "execute_kw", parameters: params)
.responseXMLRPC(queue: DispatchQueue.global(qos: .background)) {
// process result
}

我基于AlamofireXMLRPC的github源代码，但以前没有使用过它，所以可能会有一些语法错误。但它应该为你指出正确的方向。不过，我还是建议您不要阻塞线程(我重复自己，但这确实非常重要)。