我正在编写一个依赖于来自各种站点/服务的数据的应用程序,并且涉及基于这些不同来源的数据执行计算以产生最终产品。
我编写了一个示例类,下面带有两个函数,该函数从两个来源收集数据。我选择使功能不同,因为有时我们会根据源应用不同的身份验证方法,但是在本示例中,我只是将它们简化为最简单的形式。这两个功能都使用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个闭包。
找出有助于检查多个数据源是否给出有效响应的最佳方法的任何帮助,并对其进行适当处理将不胜感激。
比那个阻塞线程的循环过程更好,您可以使用调度组来跟踪请求的完成时间。因此,在发出每个请求之前先“进入”该组,在完成请求后“离开”该组,并设置一个“通知”阻止/关闭,当该组的所有任务都完成时将被调用。
例如,在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子类中(使它们可取消,使您可以控制并发程度的控制等),但这更加复杂,因此您可能要从如上所述的调度组开始。
NSOperation