xcode - 使用 NSURLSession 处理异步模式

Question

我正在使用 Xcode 7 和 Swift 2，但我的问题不一定是特定于代码的，我很乐意接受各种帮助。

在我的应用程序中，我有一个收藏夹列表。由于 API TOS，我不能存储任何数据，所以我只保留一个 stub ，当用户打开应用程序时我可以用它来查找。由于没有批处理方法，我还必须一个一个地查找每个最喜欢的。现在我有这样的东西:

 self.api.loadFavorite(id, completion: { (event, errorMessage) -> Void in
     if errorMessage == "" {
         if let rc = self.refreshControl {
             dispatch_async(dispatch_get_main_queue()) { () -> Void in
                 rc.endRefreshing()
             }
         }
         dispatch_async(dispatch_get_main_queue()) { () -> Void in
         self.viewData.append(event)
             self.viewData.sortInPlace({ $0.eventDate.compare($1.eventDate) == NSComparisonResult.OrderedDescending })
             self.tableView.reloadData()
         }
     } else {
         // some more error handling here

     }
 })

在 api.loadFavorite 中，我制作了一个典型的 urlSession.dataTaskWithURL，它本身是异步的。

您可以看到这里发生的事情是结果被一个一个地加载，并且在每个结果之后刷新 View 。这确实有效，但不是最佳选择，对于长列表，您会在 View 排序和刷新时看到明显的“闪烁”。

我希望能够获得所有结果然后只刷新一次。我尝试在 api.loadFavorites 周围放置一个调度组，但 dataTaskWith URL 中的异步调用似乎不受该组的约束。我还尝试将调度组放在 dataTaskWithURL 周围，但没有更好的运气。 dispatch_group_notify 总是在所有数据任务完成之前触发。

我做错了吗？ (可能)我考虑过在后台线程中切换到同步调用，因为 api 无论如何只允许每个客户端一个连接，但这感觉像是错误的方法。

我很想知道如何获取将其他异步调用分组的异步调用，以便我可以获得单个通知来更新我的 UI。

作为记录，我已经阅读了我可以在这里找到的每个调度组线程，但我无法使它们中的任何一个工作。网络上的大多数示例都非常简单，调度组中的一系列打印品和 sleep 证明了这一点。

提前致谢。

Answer 1

如果您想在循环中为所有喜欢的 id 异步调用您的方法 loadFavorite - 并行执行它们 - 您可以使用如下所示的新方法实现此目的:

func loadFavorites(ids:[Int], completion: ([Event], ErrorType?) -> ()) {
    var count = ids.count
    var events = [Event]()
    if count == 0 {
        dispatch_async(dispatch_get_global_queue(0, 0)) {
            completion(events, nil)
        }
        return
    }
    let sync_queue = dispatch_queue_create("sync_queue", dispatch_queue_attr_make_with_qos_class(DISPATCH_QUEUE_SERIAL, QOS_CLASS_USER_INITIATED, 0))
    for i in ids {
        self.api.loadFavorite(i) { (event, message) in
            dispatch_async(sync_queue) {
                if message == "" {
                    events.append(event)
                    if --count == 0 {
                        dispatch_async(dispatch_get_global_queue(0, 0)) {
                            completion(events, nil)
                        }
                    }
                }
                else {
                    // handle error
                }
            }
        }            
    }
}

注意:
- 使用同步队列来同步对共享阵列的访问 事件和计数器!
- 在调用完成处理程序的地方使用全局调度队列!

然后像下面这样调用它:

self.loadFavorites(favourites) { (events, error) in
    if (error == nil) {
        events.sortInPlace({ $0.eventDate.compare($1.eventDate) == NSComparisonResult.OrderedDescending })
        dispatch_async(dispatch_get_main_queue()) { () -> Void in
            self.viewData = events             
            self.tableView.reloadData()
        }    
    }
    if let rc = self.refreshControl {
        dispatch_async(dispatch_get_main_queue()) { () -> Void in
            rc.endRefreshing()
     }    
}

另请注意，当您希望确保对 loadFavorite 的调用应该是连续的时，您需要一种不同的方法。

如果你需要支持取消(好吧，谁不需要这个？)，你可以尝试取消 NSURLSession 的任务。但是，在这种情况下，我建议使用已经支持取消网络任务的第三方库。

或者，为了大大简化您的异步问题，围绕通用实用程序类构建您的网络任务和任何其他异步任务，通常称为 Future 或 Promise。 future 代表最终结果，而且很轻。它们也是“可组合的”，也就是说，您可以定义在未来完成时调用的“延续”，这又会返回另一个 future ，您可以在其中添加更多延续，等等。参见维基 Futures and Promises .

在 Swift 和 Objective-C 中有几个实现。理想情况下，这些也应该支持取消。不幸的是，我不知道目前有任何支持取消的实现 Futures 或 Promises 的 Swift 库——除了我自己的库，它还没有开源。

另一个有助于解决常见且非常复杂的异步模式的库是 ReactiveCocoa ，尽管它的学习曲线非常陡峭，并且会向您的项目添加大量代码。