iOS：使用 Grand Central Dispatch (GCD) 时如何同步我的 managedObjectContext？

Question

我正在使用以下代码来运行解析我的 xml 文件的函数...

dispatch_queue_t queue = dispatch_queue_create("updateQueue", DISPATCH_QUEUE_CONCURRENT);

dispatch_async(queue,^ { [self updateFromXMLFile:@"http://path/to/file.xml"]; } ); 
dispatch_async(queue,^ { [self updateFromXMLFile:@"http://path/to/file1.xml"]; } );
dispatch_async(queue,^ { [self updateFromXMLFile:@"http://path/to/file2.xml"]; } );
dispatch_async(queue,^ { [self updateFromXMLFile:@"http://path/to/file3.xml"]; } );

dispatch_barrier_async(queue,^ {
    dispatch_async(dispatch_get_main_queue(),^ { 
            [self setBottomBarToUpdated]; 
    });
});

下面是函数updateFromXMLFile：

- (BOOL) updateFromXMLFile:(NSString *)pathToFile {

         NSURL *url = [[NSURL alloc] initWithString:pathToFile];
         NSXMLParser *xmlParser = [[NSXMLParser alloc] initWithContentsOfURL:url];

         XMLParser *parser = [[XMLParser alloc] initXMLParser];

         parser.managedObjectContext = self.managedObjectContext;

         [xmlParser setDelegate: parser];

         BOOL success = [xmlParser parse];

         if(success)
              return TRUE;
         else
              return FALSE;

}

我遇到的问题是这个错误消息：***Terminating app due to uncaught exception 'NSGenericException', reason: '*** Collection <__NSCFSet: 0xc675e10> was mutated while being enumerated.'

我猜它与同时与我的 ManagedObjectContext 搞乱的所有进程有关。我不确定如何处理。有任何想法吗？谢谢！

Answer 1

您需要展示您的 XMLParser 如何处理其委托职责的代码，因为这就是被调用的内容。

现在，您在不同的线程中同时解析多个文件。它们都调用不同的 XMLParser 对象，但每个都使用相同的托管对象上下文 (MOC)。

如果您使用默认的 MOC 设置，则需要将所有这些 MOC 调用重新召集到主线程（如果是，确实是您第一次创建上下文的位置）。如果你使用约束，并且你的 MOC 不是在主线程上创建的，那么你给自己带来了更多的麻烦。

但是，这是一个非常简单的修复。在该解析器委托方法中，每当您使用托管对象上下文时，将其包含在调用中以在主线程上调度该部分。

dispatch_async(dispatch_get_main_queue(), ^{
    // Put your code that accesses the MOC in here.
});

现在，要批量下载到 Core Data 中，您最好使用两种方法之一。

创建一个新的 MOC，直接连接到持久存储协调器，并在那里进行所有保存。您的主要 MOC 需要观察保存通知并合并这些更改。

或者，使新的 MOC 成为您的主 MOC 的子 MOC，并直接保存到其中，然后它可以保存。

但是，如果您的托管对象上下文是 NSMainQueueConcurrencyType 或 NSPrivateQueueConcurrency 类型（上述第二个选项的唯一方法），那么您可以使用它的 perfromBlock 方法...

[managedObjectContext performBlock:^{
    // Do your MOC stuff in here
}];

最重要的是，可以使用三种并发类型之一来创建 MOC。如果它是 NSConfinementConcurrencyType，那么你不能在创建它的线程之外触摸它。如果是 NSMainQueueConcurrencyType，则必须使用 performBlock* 或仅在主线程中触摸它。如果是 NSPrivateConcurrencyType，则必须使用 performBlock*。

Answer 2

问题是您不能使用并发队列来连接 MOC，您必须使用串行队列。将您的队列创建更改为

dispatch_queue_t queue = dispatch_queue_create("updateQueue", DISPATCH_QUEUE_SERIAL);

一切都会好起来的。同样，这样做的原因是最终的 XMLParser 对象同时尝试与 moc 交互。

您的选择取决于 XMLParser（或任何类）正在做什么。如果一个类在与 MOC 交互之前完成了繁重的工作，或者它从 Web 下载数据，那么您将通过并发获得一些好处。

我建议您从 URL 下载所需的数据，然后使用 MOC 串行工作。您必须在单个线程（在 iOS 中）上与 MOC 交互，但这不一定是 mainThread - 它可以是任何线程，只要它只是一个线程即可。这意味着如果您创建自己的串行队列，则必须在该队列上完成所有工作，包括创建 MOC！

回到您的代码。让我们假设您在 mainQueue 上完成所有核心数据工作（目前）。解决方案是将您的代码更改为：

dispatch_async(dispatch_get_global_queue(0,0) {
  NSURL *url = [[NSURL alloc] initWithString:pathToFile];
  NSData *data = [NSData dataWithContentsOfURL:url];
  NSXMLParser *xmlParser = [[NSXMLParser alloc] initWithData:data];
  XMLParser *parser = [[XMLParser alloc] initXMLParser];
  parser.managedObjectContext = self.managedObjectContext;
  [xmlParser setDelegate: parser];

  dispatch_async(dispatch_get_main_queue(), {
         BOOL success = [xmlParser parse];

         // need some means to associate success/failure with the URL
  } );

您可以同时执行尽可能多的操作，即在点击 MOC 时进行序列化。当您为 MOC 使用串行队列时，唯一的区别是您将向该队列而不是 mainQueue 发送消息。