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

Question

我正在使用JSON获取两种类型的信息，并且我使用addObserver（forKeyPath：“operations”...）将“操作”添加到2个不同的操作队列类中。在函数observeValue中，我正在检查operationQueue1.operations.isEmpty，然后我在UI中刷新我的信息。我在使用operationQueue2的if else做同样的事情，但是当有时启动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是你想要做的wrong tool。正如旧的“水晶探索”游戏的说明所说，这有点像使用高射炮杀死蚊子。

从我上面的代码中可以看出，看起来你正在使用KVO来安排一个通知，告知你提交给队列的操作或一组操作何时完成。根据你的dataTask方法实际做了什么，这是我要做的事情：

• 如果只提交一个操作：将操作的completionBlock属性设置为一个刷新表信息的闭包。
• 如果您提交了多个操作：创建一个新的BlockOperation来刷新您的表信息，并使用您提交到队列的每个其他操作调用该操作的addDependency。然后，提交该操作。

这将为您提供更清洁，更无故障的方法来监控您的任务完成情况。而且由于您不再需要队列完全清空，您甚至可能不再需要使用两个单独的队列，具体取决于您正在使用的其他队列。