在 performBlockAndWait 块中执行 fetch 请求时核心数据死锁

Question

我遇到了无法解决的 Core Data 问题。我已经通过艰难的方式了解了 Core Data 中的并发问题，因此我非常小心，只在 performBlock: 和 performBlockAndWait: 块中执行任何核心数据操作。

这是我的代码：

/// Executes a fetch request with given parameters in context's block.
+ (NSArray *)executeFetchRequestWithEntityName:(NSString *)entityName
                                 predicate:(NSPredicate *)predicate
                                fetchLimit:(NSUInteger)fetchLimit
                            sortDescriptor:(NSSortDescriptor *)sortDescriptor
                                 inContext:(NSManagedObjectContext *)context{
    NSCAssert(entityName.length > 0,
          @"entityName parameter in executeFetchRequestWithEntityName:predicate:fetchLimit:sortDescriptor:inContext:\
          is invalid");

    __block NSArray * results = nil;

    NSPredicate * newPredicate = [CWFCoreDataUtilities currentUserPredicateInContext:context];
    if (predicate){
        newPredicate = [NSCompoundPredicate andPredicateWithSubpredicates:@[newPredicate, predicate]];
    }

    [context performBlockAndWait:^{

        NSFetchRequest * request = [NSFetchRequest fetchRequestWithEntityName:entityName];
        request.fetchLimit = fetchLimit;
        request.predicate = newPredicate;
        if (sortDescriptor) {
            request.sortDescriptors = @[sortDescriptor];
        }

        NSError * error = nil;
        results = [context executeFetchRequest:request error:&error];

        if (error){
            @throw [NSException exceptionWithName:NSInternalInconsistencyException
                                           reason:@"Fetch requests are required to succeed."    
                                         userInfo:@{@"error":error}];
             NSLog(@"ERROR! %@", error);
        }

        NSCAssert(results != nil, @"Fetch requests must succeed");
    }];

    return results;
}

当我从两个不同的线程同时进入此方法并传递两个不同的上下文时，我会导致此行出现死锁：results = [context executeFetchRequest:request error:&error];

有趣的是：似乎两个线程都无法在 Persistent Store Coordinator 上获取一些锁来执行获取请求。

我所有的上下文都是NSPrivateQueueConcurrencyType。

我无法解决问题，为什么我要锁定应用程序以及我应该采取哪些不同的做法。我对 Stack Overflow 的研究没有给我任何帮助，因为大多数人通过在 MOC 的队列上分派获取请求来修复所有锁，而我已经这样做了。

我将不胜感激有关此问题的任何信息。随时提供文档链接和其他长篇文章：我渴望了解更多关于各种并发问题和策略的信息。

Answer 1

有趣的是：似乎两个线程都无法在 Persistent Store Coordinator 上获取一些锁以执行获取请求。

持久存储协调器是一个串行队列。如果一个上下文正在访问它，另一个上下文将被阻止。

来自Apple Docs：

协调器的作用与提供并发性相反——它们序列化操作。如果你想为不同的写操作使用多个线程，你可以使用多个协调器。请注意，如果多个线程直接与协调器一起工作，则它们需要显式地锁定和解锁它。

如果您需要同时执行多个后台获取请求，您将需要多个持久存储协调器。

多个协调器只会使您的代码稍微复杂一些，但应尽可能避免。您真的需要同时进行多次提取吗？你能做一个更大的提取然后过滤内存中的结果吗？

Answer 2

如果您有兴趣了解有关 Core Data（和线程）的更多信息，以下网站将非常有帮助。我参加了 Matthew Morey 在 2013 年亚特兰大 CocoaConf 的演讲。

高性能核心数据 (http://highperformancecoredata.com)

该网站的配套示例代码位于：https://github.com/mmorey/MDMHPCoreData

您需要在您的应用程序中做的就是拥有一个 MDMPersistenceStack 类的 Singleton 实例（某处）。

就您的问题/问题而言，即使 NSManagedObjectContext 类的 Apple 文档确实允许按照您的方式编写代码（在块中的 NSManagedObjectContext 实例上执行核心数据操作）和一些程度鼓励这一点 - 我想指出这不是唯一的方法。

每当我修复了存在 Core Data 并发问题（锁定）的应用程序时，我认为最简单的方法是在我想要执行 Core Data 操作的线程或块内创建一个私有 NSManagedObjectContext。

这可能不是最优雅的方法，但它从未让我失望。始终保证 NSManagedObjectContext 是在同一个线程中创建和执行的，因为 NSManagedObjectContext 是显式创建的。

dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);

dispatch_async(queue, ^{
      /* 
         Create NSManagedObjectContext
         Concurrency of Managed Object Context should be set to NSPrivateQueueConcurrencyType
         If you use the MDMPersistenceStack class this is handled for you.
      */
      NSManagedObjectContext *managedObjectContext = ....  

      /*
         Call the method that you have listed in your code.  
         Let's assume that this class method is in MyClass
         Remove the block that you have in your method, as it's not needed 
      */
      [MyClass executeFetchRequestWithEntityName: ......]   // rest of parameters
});

Answer 3

我是这样做的。它为我解决了这个问题。我也遇到了很多死锁。看看它是否适合你。

    + (NSArray *)getRecordsForFetchRequest:(NSFetchRequest *)request inContext:(NSManagedObjectContext *)context
{


@try
{
   __weak __block NSError *error = nil;

    __block __weak NSArray *results = nil;


    [context performBlockAndWait:^{
        [context lock];

        results = [context executeFetchRequest:request error:&error];

        [context processPendingChanges];

        [context unlock];

    }];

    [self handleErrors:error];

    request = nil;
    context = nil;

    return results;
}
@catch (NSException *exception)
{
    if([exception.description rangeOfString:@"Can only use -performBlockAndWait: on an NSManagedObjectContext that was created with a queue"].location!=NSNotFound)
    {
        NSError *error = nil;

        [context lock];

       __weak NSArray *results = [context executeFetchRequest:request error:&error];

        [context processPendingChanges];

        [context unlock];

        [self handleErrors:error];

        request = nil;
        context = nil;

        return results;
    }

    return nil;
}

}