ios – Swift /如何使用dispatch_group与多个称为Web服务的?

前端之家收集整理的这篇文章主要介绍了ios – Swift /如何使用dispatch_group与多个称为Web服务的?前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。
我正在使用dispatch_group来调用Firebase请求函数,一旦请求完成,就可以得到通知,以便能够使用结果.在这种情况下,我刚刚放了一个打印声明.
  1. func loadStuff() {
  2. dispatch_group_enter(group)
  3. myFirebaseFunction() {
  4. dispatch_group_leave(group)
  5. }
  6.  
  7. dispatch_group_notify(group,dispatch_get_main_queue()) {
  8. print("done")
  9. }
  10. }
  11.  
  12. func myFirebaseFunction(completionHandler: () -> ()) {
  13.  
  14. let usersRef = firebase.child("likes")
  15. usersRef.observeEventType(.Value,withBlock: { snapshot in
  16.  
  17. if snapshot.exists() {
  18. let sorted = (snapshot.value!.allValues as NSArray).sortedArrayUsingDescriptors([NSSortDescriptor(key: "date",ascending: false)])
  19.  
  20. for item in sorted {
  21.  
  22. dict.append(item as! NSDictionary)
  23. }
  24. }
  25. completionHandler()
  26. })
  27. }

这段代码正常工作.问题是,在运行时,数据将被添加到Firebase数据库.这就是为什么我必须使用observeEventType而不是observeSingleEventOfType.

这意味着在运行时有一个观察者,如果数据已被添加数据库中,myFirebaseFunction中的块将再次被调用.

一旦发生这种情况,应用程序崩溃,因为dispatch_group_leave(组)已调用,而没有dispatch_group_enter(组).只要我有这个权利.

  1. dispatch_group_enter(group)
  2. myFirebaseFunction() {
  3. dispatch_group_leave(group) // crash here
  4. }

如果我将其更改为observeSingleEventOfType,则不会发生崩溃,但是新添加到Firebase的数据将不会被观察到.

在多个运行的Web服务中使用dispatch_group的最佳做法是什么?或者我需要做些什么来解决我的问题?帮助非常感激.

PS目前我正在使用Swift 2.3,但是升级到Swift 3是有计划的,所以收到一个能够兼容的答案将非常棒.

解决方法

问题

正如你所说,调用dispatch_group_enter和dispatch_group_leave必须平衡.在这里,您无法平衡它们,因为执行实时实时获取呼叫的功能离开.

方法1 – 组上的所有呼叫

如果没有问题,myFirebaseFunction总是执行其在该调度组上的工作,那么您可以将它们放在里面,也可以使用beginHandler和completionHandler:

  1. func loadStuff() {
  2. myFirebaseFunction(beginHandler: {
  3. dispatch_group_enter(group)
  4. dispatch_group_notify(group,dispatch_get_main_queue()) {
  5. print("done")
  6. }
  7. },completionHandler: { dispatch_group_leave(group) })
  8.  
  9. }
  10.  
  11. func myFirebaseFunction(beginHandler: () -> (),completionHandler: () -> ()) {
  12.  
  13. let usersRef = firebase.child("likes")
  14. usersRef.observeEventType(.Value,withBlock: { snapshot in
  15.  
  16. beginHandler()
  17. if snapshot.exists() {
  18. let sorted = (snapshot.value!.allValues as NSArray).sortedArrayUsingDescriptors([NSSortDescriptor(key: "date",ascending: false)])
  19.  
  20. for item in sorted {
  21.  
  22. dict.append(item as! NSDictionary)
  23. }
  24. }
  25. completionHandler()
  26. })
  27. }

在这里,完成处理程序仍然被loadStuff设置为dispatch_group_leave,但是还有一个可以调用dispatch_group_enter和dispatch_group_notify的开始处理程序.通知需要在开始时被调用的原因是,我们需要确保我们在调用notify之前已经进入了组,或者如果组为空,则notify块将立即执行.

传递给dispatch_group_notify的块只会被精确调用一次,即使在通知调用后在组上执行了块.因此,每次自动调用observeEventType可能会对组发生安全.然后在这些功能之外的任何时候,您需要等待加载完成,您只需调用notify即可.

编辑:因为每次调用beginHandler时都会调用notify,所以这个方法实际上会导致每次调用notify块,所以可能不是一个理想的选择.

方法2 – 只有第一次呼叫组,几种方法

如果您真正需要的仅仅是第一次调用observeEventType来使用该组,那么一个选项是要有两个版本的myFirebaseFunction:一个类似于你已经拥有的版本,一个使用observeSingleEventOfType.然后加载的东西可以调用这两个函数,只有通过dispatch_group_leave作为完成其中之一:

  1. func loadStuff() {
  2. dispatch_group_enter(group)
  3. myInitialFirebaseFunction() {
  4. dispatch_group_leave(group)
  5. }
  6.  
  7. dispatch_group_notify(group,dispatch_get_main_queue()) {
  8. print("done")
  9. }
  10.  
  11. myFirebaseFunction({})
  12. }
  13.  
  14. func myInitialFirebaseFunction(completionHandler: () -> ()) {
  15.  
  16. let usersRef = firebase.child("likes")
  17. usersRef.observeSingleEventOfType(.Value,withBlock: { snapshot in
  18. processSnapshot(snapshot)
  19. completionHandler()
  20. })
  21. }
  22.  
  23. func myFirebaseFunction(completionHandler: () -> ()) {
  24.  
  25. let usersRef = firebase.child("likes")
  26. usersRef.observeSingleEventOfType(.Value,withBlock: { snapshot in
  27. processSnapshot(snapshot)
  28. completionHandler()
  29. })
  30. }
  31.  
  32. func processSnapshot(snapshot: FDataSnapshot) {
  33.  
  34. if snapshot.exists() {
  35. let sorted = (snapshot.value!.allValues as NSArray).sortedArrayUsingDescriptors([NSSortDescriptor(key: "date",ascending: false)])
  36.  
  37. for item in sorted {
  38. dict.append(item as! NSDictionary)
  39. }
  40. }
  41. }

方法3 – 只有第一次呼叫组,没有额外的方法

请注意,因为“方法2”中的loadStuff基本上是从Firebase两次加载东西,它可能没有你想要的那么高效.在这种情况下,您可以使用Bool来确定是否应该调用休假:

  1. var shouldLeaveGroupOnProcess = false
  2.  
  3. func loadStuff() {
  4. dispatch_group_enter(group)
  5. shouldLeaveGroupOnProcess = true
  6. myFirebaseFunction() {
  7. if shouldLeaveGroupOnProcess {
  8. shouldLeaveGroupOnProcess = false
  9. dispatch_group_leave(group)
  10. }
  11. }
  12.  
  13. dispatch_group_notify(group,withBlock: { snapshot in
  14.  
  15. if snapshot.exists() {
  16. let sorted = (snapshot.value!.allValues as NSArray).sortedArrayUsingDescriptors([NSSortDescriptor(key: "date",ascending: false)])
  17.  
  18. for item in sorted {
  19. dict.append(item as! NSDictionary)
  20. }
  21. }
  22. completionHandler()
  23. })
  24. }

这里,即使在初始加载期间进行了对observeEventType的多次调用,也只能保留一次调用,并且不会发生崩溃.

Swift 3

PS Currently I’m using Swift 2.3,but an upgrade to Swift 3 is planned,so it would be very awesome to receive an answer capable for both.

调度已经在Swift 3中进行了彻底的检修(它是面向对象的),所以在两者之间运行良好的代码并不是一件很重要的事情:)

但是上述三种方法的概念是一样的.在Swift 3:

>使用DispatchGroup的其中一个创建您的组> dispatch_group_enter现在是在组上输入的实例方法> dispatch_group_leave现在是组上的实例方法> dispatch_group_notify现在是组上的实例方法通知

猜你在找的iOS相关文章