Swift - 使用两个不同的OperationQueue和KVO时应用程序崩溃

Question

我正在使用JSON获取两种类型的信息,并且我使用addObserver(forKeyPath:"operations"...)将"操作"添加到2个不同的操作队列类中.在函数observeValue中,我正在检查operationQueue1.operations.isEmpty,然后我在UI中刷新我的信息.我正在使用ifQalue2执行相同的操作,但是当有时启动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()观察将被再次调用，导致另一个取消注册块被提交到主队列。

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

您可能可以通过使用 Swift 4 的基于块的观察者来解决此问题（假设代码没有更多此类性质的问题），并将观察者设置为nil而不是显式取消注册它。但是，我认为 KVO对于您想要做的事情来说是错误的工具。正如旧版《Crystal Quest》游戏的说明中所说，这有点像用高射炮杀死蚊子。

从上面的代码中我可以看到，您使用 KVO 似乎只是为了在您提交到队列的一个或一组操作完成时安排通知。根据您的dataTask方法实际执行的操作，我会这样做：

• 如果您仅提交一项操作：将该操作的completionBlock属性设置为刷新表信息的闭包。

• 如果您提交多个操作：创建一个新操作BlockOperation来刷新您的表信息，并addDependency与您提交到队列的每个其他操作一起调用该操作。然后，提交该操作。

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