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. 
}); 

现在，对于批量下载到核心数据中，您最好使用两种方法之一。

创建一个新的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交互之前做了繁重的工作，或者它从网上下载数据，那么你会通过并发获得一些东西。

我建议你做的是从URLS下载你需要的数据，然后连续与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。