检查来自 Alamofire 和 Swift 的多个异步响应
Checking for multiple asynchronous responses from Alamofire and Swift
我正在编写一个依赖于来自各种 sites/service 的数据的应用程序,并涉及根据来自这些不同来源的数据执行计算以生成最终产品。
我写了一个例子 class,下面有两个函数可以从两个来源收集数据。我选择了不同的功能,因为有时我们会根据来源应用不同的身份验证方法,但在这个例子中,我只是将它们简化为最简单的形式。这两个函数都使用 Alamofire 来触发和处理请求。
然后我有一个初始化函数,它说如果我们已经成功地从两个来源收集数据,然后加载另一个 nib 文件,否则等待几秒钟,如果没有返回响应,然后加载服务器错误 nib文件。
我已尽力使这个示例尽可能简单。本质上。这就是我想要遵循的逻辑。不幸的是,这似乎目前在其当前实施中不起作用。
import Foundation
class GrabData{
var data_source_1:String?
var data_source_2:String?
init(){
// get data from source 1
get_data_1{ data_source_1 in
println("\(data_source_1)")
}
// get data from source 2
get_data_2{ data_source_1 in
println("\(data_source_1)")
}
var timer = 0;
while(timer<5){
if((data_source_1 == nil) && (data_source_2 == nil)){
// do nothing unless 4 seconds has elapsed
if (timer == 4){
// load server error nib
}
}else{
// load another nib, and start manipulating data
}
// sleep for 1 second
sleep(1)
timer = timer+1
}
}
func get_data_1(completionHandler: (String) -> ()) -> () {
if let datasource1 = self.data_source_1{
completionHandler(datasource1)
}else{
var url = "http://somewebsite.com"
Manager.sharedInstance.request(.GET, url).responseString {
(request, response, returnedstring, error) in
println("getting data from source 1")
let datasource1 = returnedstring
self.data_source_1 = datasource1
completionHandler(datasource1!)
}
}
}
func get_data_2(completionHandler: (String) -> ()) -> () {
if let datasource2 = self.data_source_2{
completionHandler(datasource2)
}else{
var url = "http://anotherwebsite.com"
Manager.sharedInstance.request(.GET, url).responseString {
(request, response, returnedstring, error) in
println("getting data from source 2")
let datasource2 = returnedstring
self.data_source_2 = datasource2
completionHandler(datasource2!)
}
}
}
}
我知道我可以将第二个闭包放在 init 函数中的第一个闭包中,但是,我认为这不是最佳实践,而且我实际上是从两个以上的来源中提取数据,因此闭包将是n 闭包深度。
任何有助于找出检查多个数据源是否给出有效响应并适当处理的最佳方法的帮助将不胜感激。
比会阻塞线程的循环过程更好的是,您可以使用分派组来跟踪请求何时完成。所以 "enter" 在发出每个请求之前的组, "leave" 在请求完成时的组,并设置一个 "notify" block/closure ,当所有的小组任务完成。
例如,在Swift 3:
let group = DispatchGroup()
group.enter()
retrieveDataFromURL(url1, parameters: firstParameters) {
group.leave()
}
group.enter()
retrieveDataFromURL(url2, parameters: secondParameters) {
group.leave()
}
group.notify(queue: .main) {
print("both requests done")
}
或者,在 Swift 2:
let group = dispatch_group_create()
dispatch_group_enter(group)
retrieveDataFromURL(url1, parameters: firstParameters) {
dispatch_group_leave(group)
}
dispatch_group_enter(group)
retrieveDataFromURL(url2, parameters: secondParameters) {
dispatch_group_leave(group)
}
dispatch_group_notify(group, dispatch_get_main_queue()) {
print("both requests done")
}
另一种方法是将这些请求包装在异步 NSOperation
子类中(使它们可取消,让您控制并发程度的约束等),但这更复杂,因此您可能需要如上所示从调度组开始。
我正在编写一个依赖于来自各种 sites/service 的数据的应用程序,并涉及根据来自这些不同来源的数据执行计算以生成最终产品。
我写了一个例子 class,下面有两个函数可以从两个来源收集数据。我选择了不同的功能,因为有时我们会根据来源应用不同的身份验证方法,但在这个例子中,我只是将它们简化为最简单的形式。这两个函数都使用 Alamofire 来触发和处理请求。
然后我有一个初始化函数,它说如果我们已经成功地从两个来源收集数据,然后加载另一个 nib 文件,否则等待几秒钟,如果没有返回响应,然后加载服务器错误 nib文件。
我已尽力使这个示例尽可能简单。本质上。这就是我想要遵循的逻辑。不幸的是,这似乎目前在其当前实施中不起作用。
import Foundation
class GrabData{
var data_source_1:String?
var data_source_2:String?
init(){
// get data from source 1
get_data_1{ data_source_1 in
println("\(data_source_1)")
}
// get data from source 2
get_data_2{ data_source_1 in
println("\(data_source_1)")
}
var timer = 0;
while(timer<5){
if((data_source_1 == nil) && (data_source_2 == nil)){
// do nothing unless 4 seconds has elapsed
if (timer == 4){
// load server error nib
}
}else{
// load another nib, and start manipulating data
}
// sleep for 1 second
sleep(1)
timer = timer+1
}
}
func get_data_1(completionHandler: (String) -> ()) -> () {
if let datasource1 = self.data_source_1{
completionHandler(datasource1)
}else{
var url = "http://somewebsite.com"
Manager.sharedInstance.request(.GET, url).responseString {
(request, response, returnedstring, error) in
println("getting data from source 1")
let datasource1 = returnedstring
self.data_source_1 = datasource1
completionHandler(datasource1!)
}
}
}
func get_data_2(completionHandler: (String) -> ()) -> () {
if let datasource2 = self.data_source_2{
completionHandler(datasource2)
}else{
var url = "http://anotherwebsite.com"
Manager.sharedInstance.request(.GET, url).responseString {
(request, response, returnedstring, error) in
println("getting data from source 2")
let datasource2 = returnedstring
self.data_source_2 = datasource2
completionHandler(datasource2!)
}
}
}
}
我知道我可以将第二个闭包放在 init 函数中的第一个闭包中,但是,我认为这不是最佳实践,而且我实际上是从两个以上的来源中提取数据,因此闭包将是n 闭包深度。
任何有助于找出检查多个数据源是否给出有效响应并适当处理的最佳方法的帮助将不胜感激。
比会阻塞线程的循环过程更好的是,您可以使用分派组来跟踪请求何时完成。所以 "enter" 在发出每个请求之前的组, "leave" 在请求完成时的组,并设置一个 "notify" block/closure ,当所有的小组任务完成。
例如,在Swift 3:
let group = DispatchGroup()
group.enter()
retrieveDataFromURL(url1, parameters: firstParameters) {
group.leave()
}
group.enter()
retrieveDataFromURL(url2, parameters: secondParameters) {
group.leave()
}
group.notify(queue: .main) {
print("both requests done")
}
或者,在 Swift 2:
let group = dispatch_group_create()
dispatch_group_enter(group)
retrieveDataFromURL(url1, parameters: firstParameters) {
dispatch_group_leave(group)
}
dispatch_group_enter(group)
retrieveDataFromURL(url2, parameters: secondParameters) {
dispatch_group_leave(group)
}
dispatch_group_notify(group, dispatch_get_main_queue()) {
print("both requests done")
}
另一种方法是将这些请求包装在异步 NSOperation
子类中(使它们可取消,让您控制并发程度的约束等),但这更复杂,因此您可能需要如上所示从调度组开始。