1

我是 dispatch_queue 的新手，尝试在后台保存到 CoreData 时遇到了问题。我已阅读 CoreData 编程指南，并且NSManagedObjectContext在后台线程中创建了一个单独的。当我在测试项目中执行一个简单的循环来创建NSManagedObjects 时，我没有任何问题，创建了对象并使用 将NSManageObjectContextDidSaveNotification更改传达给主线程。

我相信我的问题在于我对 GCD 的无知。我正在解析 XML，parserDidEndDocument:我需要在不阻塞 UI 的情况下将数据保存到 CoreData。每当使用这个块时，我的应用程序内存开始不受控制地滚雪球，直到最后我得到Terminated app due to memory pressure.

注意：我使用 AppDelegate 的单例来保存我的NSPersistentStoreCoordinator东西，而 stuffToSave 是NSMutablearray由我的解析器创建的。

任何方向将不胜感激。这两天我一直在打我的头！

-(void)parserDidEndDocument:(NSXMLParser *)parser

dispatch_queue_t backgroundQ = dispatch_queue_create("com.example.myapp", NULL);

__block AppDelegate *app= [[UIApplication sharedApplication]delegate];
__block NSMutableArray *array = self.stuffToSave;


dispatch_async(backgroundQ, ^(void){

    NSManagedObjectContext *context = [[NSManagedObjectContext alloc] init];
    context.persistentStoreCoordinator = [app persistentStoreCoordinator];

    HNField *field = [HNField fieldWithField_id:[NSNumber numberWithInt:0] inContext:context];
    //initalize array if needed
    if (!field.arrayOfPolylines) field.arrayOfPolylines = [[NSMutableArray alloc]init];

    //add polyline to array to save in database
    for (id obj in array) {
        if ([obj isKindOfClass:[HNPolyline class]]) {
            HNPolyline *theLine = (HNPolyline *)obj;
            [field.arrayOfPolylines addObject:theLine];
        }else if ([obj isKindOfClass:[HNParserPoint class]]){
            HNPoint *point = [HNPoint createAPointWithContext:context];
            HNParserPoint *pPoint = (HNParserPoint *)obj;
            point.point_id = pPoint.point_id;
            point.lat = pPoint.lat;
            point.lng = pPoint.lng;
            point.yield = pPoint.yield;
            point.farm_id = self.farm_id;
            point.field_id = self.field_id;
            point.inField = field;
            //add every point in database
            [field addFieldPointsObject:point];
        }
    }
    NSError *error;
    [context save:&error];

       });



self.stuffToSave = nil;
self.parser = nil;
}

编辑1： 我正在NSManageObjectContextDidSaveNotification从与我正在解析的地方不同的班级收听。在viewDidLoad我有：

// observe the ParseOperation's save operation with its managed object context
[[NSNotificationCenter defaultCenter] addObserver:self
                                         selector:@selector(didSave:)
                                             name:NSManagedObjectContextDidSaveNotification
                                           object:nil];

然后我使用 Apple 的“ThreadedCoreData”示例中的以下内容。

-(void)didSave:(NSNotification *)notification{

    if (notification.object != [self.app managedObjectContext]) {
        NSLog(@"not main context");
        [self performSelectorOnMainThread:@selector(updateMainContext:) withObject:notification waitUntilDone:NO];
    }else{
         NSLog(@"b Thread: %@",[NSThread currentThread]);
       NSLog(@"main context");
    }
}

// merge changes to main context
- (void)updateMainContext:(NSNotification *)notification {

    assert([NSThread isMainThread]);
    [[self.app managedObjectContext] mergeChangesFromContextDidSaveNotification:notification];
    NSLog(@"did save");
}
4

2 回答 2

1

也许我无法正确理解，但从我所看到的情况来看，我会避免一些事情。

我可能错了，但我认为问题在于您正在后台队列上启动异步操作，但您最终使用的是默认上下文队列，您保证它是线程安全的，但事实并非如此。因此，当您保存时，您会发送通知，这会触发保存等，直到您填满内存。要验证这一点，请尝试在 updateMainContext 中放置一个断点，并查看它被调用了多少次。

如果您使用不同的上下文，您应该使用 NSPrivateQueueConcurrencyType 对其进行初始化，这样您就可以确保所有工作都在单独的线程中完成。所以我会像这样重温dispatch async，在这种情况下你可以这样做来代替dispatch_async：

NSManagedObjectContext *privateCtx = [[NSManagedObjectContext alloc] initWithConcurrencyType:NSPrivateQueueConcurrencyType]; 

[privateCtx performBlock:^() {
  // put the code you have in dispatch async...
}];

然后在另一个类上，您应该找到一种仅侦听私有上下文的方法，当然您需要参考。如果你不能，我想避免来自主线程的任何东西都很好，如果那个类只是从后台合并的一个点。

于 2013-12-18T16:29:46.923 回答
0

当我发布我正在使用 Google Maps SDK (1.6.1.6332) 并且 google maps sdk 也使用核心数据时，我没有提及或意识到。我在我的应用程序委托中观察NSManagedObjectContextDidSaveNotification，但未能过滤通知。因此，谷歌地图正在发送，NSManagedObjectContextDidSaveNotification而我的应用程序试图合并这些更改，这是我的问题的根源。

我不知道这是否是最好的解决方案，但适用于我的目的。因为我在我的应用程序委托中测试通知，所以我只有一个对我的主 MOC 的引用，所以我用它来确保通知不是来自它，然后我通过测试来测试通知是否来自感兴趣的类通知的字符串描述（其中包含需要合并的感兴趣类的多个实例）。这样做会阻止谷歌地图尝试将其更改与我的模型合并。支持@Leonardo 的意见，最终得出答案。

- (void)mergeChanges:(NSNotification *)notification {

    NSLog(@"saved changes called");
    if (notification.object != self.managedObjectContext) {
        NSLog(@"call was not main MOC");
        NSString *testingString = notification.description;
        if ([testingString rangeOfString:@"HNDemoResponse"].location != NSNotFound) {
            [self performSelectorOnMainThread:@selector(updateMainContext:) withObject:notification waitUntilDone:YES];
        }else NSLog(@"call was goole maps");
    }
}
于 2014-01-03T15:26:36.633 回答