Swift - 在 KVO 中使用两个不同的 OperationQueues 时应用程序崩溃

Question

我通过 JSON 获得了两种类型的信息，并且我正在使用 addObserver(forKeyPath:"operations"...) 向 2 个不同的操作队列类添加“操作”。在函数 observeValue 中，我正在检查 operationQueue1.operations.isEmpty 是否存在，然后在 UI 中刷新我的信息。我用 if else 和 operationQueue2 做同样的事情，但是当这 2 个操作在某个时候开始时，应用程序崩溃并显示错误消息:*** Terminating app due to uncaught exception 'NSRangeException', reason: 'Cannot remove an observer <AppName.ViewController 0x102977800> for the key path "operations" from <AppName.OperationQueue1 0x1c4a233c0> because it is not registered as an observer .'仅启动 1 个操作时我没有问题。有什么建议吗？

func getInfo1(){//runned in viewDidLoad
  operationQueue1.addObserver(forKeyPath:"operations"...)
  operationQueue1.dataTask(URL:"..."....){
      DispatchQueue.main.async{
  NotificationCenter.default.postNotification(NSNotification.Name(rawValue: "NewDataReceived1", userInfo:infoFromTheWebsite)
      }
  }
}

func NewDataReceived1(){
  here I add the information to arrays to be loaded in tableView1
}

HERE IS THE CODE FOR 2ND INFO WHICH IS THE SAME

override func observeValue(forKeyPath keyPath: String?, ....){
        if(object as? operationQueue1 == operationQueue1Class && keyPath == "operations" && context == context1){
             if(operationQueue1.operations.isEmpty){
                  DispatchQueue.main.async{
                        operationQueue1..removeObserver(self, forKeyPath:"operations")
                        Timer.scheduled("refreshingTableInformation1") 
                   }
             }
        }else if(operationQueue2....){
             SAME AS OPERATION 1, BUT USING DIFFERENT FUNC TO REFRESH TABLE INFORMATION AND THE TABLES ARE DIFFERENT
        }else{
            super.observeValue(forKeyPath: keyPath, of: object, change: change, context: context)
        }
}

func refreshingTableInformation1(){
     tableView1.reloadData()
     Timer.scheduled("getInfo1", repeat:false)
}

func refreshingTableInformation2(){
     tableView2.reloadData()
     Timer.scheduled("getInfo2", repeat:false)
}

有时工作 10 秒然后崩溃，有时工作超过 60 秒然后崩溃...

Answer 1

此处的代码容易受到竞争条件的影响。考虑以下场景:

1. getInfo1()被调用，它向 operationQueue1 添加了一个操作.

2. 操作完成，这意味着您的 KVO 观察被调用。队列现在是空的，因此您的观察会安排从主调度队列中移除您的观察者。

3. 现在，在您提交到主队列的操作能够运行之前，其他东西会调用 getInfo1() , 它向 operationQueue1 添加了一个新操作，它在您在第 2 步中排队的操作有机会运行之前完成(嘿，也许主队列正忙于某些事情；这很容易发生，因为它是一个串行队列)。

4. 您对第一次调用 getInfo1() 的观察 在队列为空时再次被调用，导致另一个取消注册 block 被提交到主队列。

5. 两个注销 block 最终在主队列上执行。第二个使程序崩溃，因为您已经注销了您的观察者。

您可能可以通过使用 Swift 4 的基于 block 的观察器并将观察器设置为 nil 来解决这个问题(假设代码没有更多这种性质的问题)而不是明确注销它。但是，我建议 KVO 是 wrong tool对于你正在尝试做的事情。正如以前“ Crystal 探秘”游戏的说明所说，这有点像用高射炮杀死蚊子。

从我从上面的代码中可以看出，您似乎只是在使用 KVO 来安排一个通知，以便在您提交给队列的一个操作或一组操作完成时发出通知。取决于你的dataTask方法确实如此，下面是我要做的:

• 如果您只提交一个操作:设置操作的 completionBlock属性到一个闭包，刷新你的表信息。

• 如果您提交多个操作:创建一个新的 BlockOperation这会刷新您的表信息，并调用 addDependency该操作与您提交给队列的所有其他操作。然后，提交该操作。

这将为您提供一种更简洁、更无故障的方式来监控您的任务完成情况。由于您不再需要队列完全清空，您甚至可能不必再使用两个单独的队列，具体取决于您对它们进行的其他操作。