使用 NSURLSession 处理异步模式

Question

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

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

 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({ [=10=].eventDate.compare(.eventDate) == NSComparisonResult.OrderedDescending })
             self.tableView.reloadData()
         }
     } else {
         // some more error handling here

     }
 })

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

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

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

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

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

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

提前致谢。

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
                }
            }
        }            
    }
}

注：
- 使用同步队列来同步对共享阵列的访问 events 和计数器！
- 使用调用完成处理程序的全局调度队列！

然后像下面这样调用它：

self.loadFavorites(favourites) { (events, error) in
    if (error == nil) {
        events.sortInPlace({ [=11=].eventDate.compare(.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 的任务。但是，在这种情况下，我建议使用已经支持取消网络任务的第三方库。

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

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

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

Answer 2

这就是最终对我有用的方法。一旦我想通了就容易了。我的问题是尝试使用 ObjC 示例并为 swift.

修改它们

func migrateFavorites(completion:(error: Bool) -> Void) {
    let migrationGroup = dispatch_group_create()
    let queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0)

    // A lot of other code in there, fetching some core data etc

    dispatch_group_enter(migrationGroup)
    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({ [=10=].eventDate.compare(.eventDate) == NSComparisonResult.OrderedDescending })
             self.tableView.reloadData()
         }
     } else {
     // some more error handling here

     }
        dispatch_group_leave(migrationGroup)
     })

    dispatch_group_notify(migrationGroup, queue) { () -> Void in
        NSLog("Migration Queue Complete")
         dispatch_async(dispatch_get_main_queue()) { () -> Void in
             completion(error: migrationError)
         }
     }
}

关键是：在异步调用之前进入组将组保留为完成处理程序中的最后一行

正如我提到的，所有这些都包含在一个函数中，所以我将函数的完成处理程序放在 dispatch_group_notify 中。所以我调用这个函数，完成处理程序只在所有异步任务完成时被调用。回到我的主线程，我检查错误并刷新 ui.

希望这对遇到同样问题的人有所帮助。

使用 NSURLSession 处理异步模式

struggling with asynchronous patterns using NSURLSession

xcode

design-patterns

asynchronous

swift

swift2