Универсальный подход к NSManagedObjectContext в многопоточном приложении

Question

Я прочитал несколько постов здесь о NSManagedObjectContext и многопоточных приложениях. Я также рассмотрел пример CoreDataBooks, чтобы понять, как отдельным потокам требуется собственный NSManagedObjectContext, и как операция сохранения объединяется с основным NSManagedObjectContext. Я нашел пример, который был хорошим, но также и слишком специфичным для приложения. Я пытаюсь обобщить это, и задаюсь вопросом, является ли мой подход обоснованным.

Мой подход заключается в том, чтобы иметь универсальную функцию для извлечения NSManagedObjectContext для текущего потока. Функция возвращает NSManagedObjectContext для основного потока, но создаст новый (или извлечет его из кэша), если вызывается из другого потока. Это выглядит следующим образом:

+(NSManagedObjectContext *)managedObjectContext {
    MyAppDelegate *delegate = (MyAppDelegate *)[[UIApplication sharedApplication] delegate];
    NSManagedObjectContext *moc = delegate.managedObjectContext;

    NSThread *thread = [NSThread currentThread];

    if ([thread isMainThread]) {
        return moc;
    }

    // a key to cache the context for the given thread
    NSString *threadKey = [NSString stringWithFormat:@"%p", thread];

    // delegate.managedObjectContexts is a mutable dictionary in the app delegate
    NSMutableDictionary *managedObjectContexts = delegate.managedObjectContexts;

    if ( [managedObjectContexts objectForKey:threadKey] == nil ) {
        // create a context for this thread
        NSManagedObjectContext *threadContext = [[[NSManagedObjectContext alloc] init] autorelease];
        [threadContext setPersistentStoreCoordinator:[moc persistentStoreCoordinator]];
        // cache the context for this thread
        [managedObjectContexts setObject:threadContext forKey:threadKey];
    }

    return [managedObjectContexts objectForKey:threadKey];
}

Операции сохранения просты, если вызваны из основного потока. Операции сохранения, вызываемые из других потоков, требуют слияния в основном потоке. Для этого у меня есть общая функция commit:

+(void)commit {
    // get the moc for this thread
    NSManagedObjectContext *moc = [self managedObjectContext];

    NSThread *thread = [NSThread currentThread];

    if ([thread isMainThread] == NO) {
        // only observe notifications other than the main thread
        [[NSNotificationCenter defaultCenter] addObserver:self
                                             selector:@selector(contextDidSave:)
                                                 name:NSManagedObjectContextDidSaveNotification
                                               object:moc];
    }

    NSError *error;
    if (![moc save:&error]) {
        // fail
    }

    if ([thread isMainThread] == NO) {
        [[NSNotificationCenter defaultCenter] removeObserver:self 
                                                    name:NSManagedObjectContextDidSaveNotification 
                                                  object:moc];
    }
}

В функции contextDidSave: мы выполняем слияние, если оно вызывается уведомлением в commit.

+(void)contextDidSave:(NSNotification*)saveNotification {
    MyAppDelegate *delegate = (MyAppDelegate *)[[UIApplication sharedApplication] delegate];
    NSManagedObjectContext *moc = delegate.managedObjectContext;

    [moc performSelectorOnMainThread:@selector(mergeChangesFromContextDidSaveNotification:)
                      withObject:saveNotification
                   waitUntilDone:YES];
}

Наконец, мы очищаем кеш NSManagedObjectContext следующим образом:

+(void)initialize {
    [[NSNotificationCenter defaultCenter] addObserver:self 
                                             selector:@selector(threadExit) 
                                                 name:NSThreadWillExitNotification 
                                               object:nil]; 
}

+(void)threadExit {
    MyAppDelegate *delegate = (MyAppDelegate *)[[UIApplication sharedApplication] delegate];
    NSString *threadKey = [NSString stringWithFormat:@"%p", [NSThread currentThread]];  
    NSMutableDictionary *managedObjectContexts = delegate.managedObjectContexts;    

    [managedObjectContexts removeObjectForKey:threadKey];
}

Это компилируется и, похоже, работает, но я знаю, что проблемы с потоками могут быть сложными из-за условий гонки. Кто-нибудь видит проблемы с этим подходом?

Кроме того, я использую это в контексте асинхронного запроса (используя ASIHTTPRequest), который выбирает некоторые данные с сервера, обновляет и вставляет хранилище на iPhone. Кажется, что NSThreadWillExitNotification не запускается после завершения запроса, и этот же поток затем используется для последующих запросов. Это означает, что тот же NSManagedObjectContext используется для отдельных запросов в том же потоке. Это проблема?

Answer 1

Через год после публикации этого вопроса я наконец-то создал структуру для обобщения и упрощения моей работы с Core Data. Это выходит за рамки первоначального вопроса и добавляет ряд функций, облегчающих взаимодействие с Core Data. Подробности здесь: https://github.com/chriscdn/RHManagedObject

Answer 2

Я нашел решение после окончательного понимания проблемы.Мое решение не имеет прямого отношения к вышеуказанному вопросу, но в первую очередь решает проблему того, почему мне пришлось иметь дело с потоками.

Мое приложение использует библиотеку ASIHTTPRequest для асинхронных запросов.Я получаю некоторые данные с сервера и использую функцию делегата requestFinished для добавления / изменения / удаления моих объектов основных данных.Функция requestFinished выполнялась в другом потоке, и я предположил, что это естественный побочный эффект асинхронных запросов.

После более глубокого анализа я обнаружил, что ASIHTTPRequest намеренно выполняет запрос в отдельном потоке, нобыть переопределенным в моем подклассе ASIHTTPRequest:

+(NSThread *)threadForRequest:(ASIHTTPRequest *)request {
    return [NSThread mainThread];
}

Это небольшое изменение помещает requestFinished в основной поток, что избавило меня от необходимости заботиться о потоках в моем приложении.