Core Data Concurrency

Concurrency is the ability to work with the data on more than one queue at the same time. If you choose to use concurrency with Core Data, you also need to consider the application environment. For the most part, AppKit and UIKit are not thread-safe. In OS X in particular, Cocoa bindings and controllers are not threadsafe — if you are using these technologies, multithreading may be complex.

Core Data, Multithreading, and the Main Thread

In Core Data, the managed object context can be used with two concurrency patterns, defined by NSMainQueueConcurrencyType and NSPrivateQueueConcurrencyType.

NSMainQueueConcurrencyType is specifically for use with your application interface and can only be used on the main queue of an application.

The NSPrivateQueueConcurrencyType configuration creates its own queue upon initialization and can be used only on that queue. Because the queue is private and internal to the NSManagedObjectContext instance, it can only be accessed through the performBlock: and the performBlockAndWait: methods.

In both cases, the initialization of the NSManagedObjectContextinstance is the same:

OBJECTIVE-C

1. NSManagedObjectContext *moc = [[NSManagedObjectContext alloc] initWithConcurrencyType:<#type#>];

SWIFT

1. let moc = NSManagedObjectContext(concurrencyType:<#type#>)

The parameter being passed in as part of the initialization will determine what type of NSManagedObjectContext is returned.

Using a Private Queue to Support Concurrency

In general, avoid doing data processing on the main queue that is not user-related. Data processing can be CPU-intensive, and if it is performed on the main queue, it can result in unresponsiveness in the user interface. If your application will be processing data, such as importing data into Core Data from JSON, create a private queue context and perform the import on the private context. The following example shows how to do this:

OBJECTIVE-C

1. NSArray *jsonArray = …; //JSON data to be imported into Core Data
2. NSManagedObjectContext *moc = …; //Our primary context on the main queue
4. NSManagedObjectContext *private = [[NSManagedObjectContext alloc] initWithConcurrencyType:NSPrivateQueueConcurrencyType];
5. [private setParentContext:moc];
7. [private performBlock:^{
8. for (NSDictionary *jsonObject in jsonArray) {
9. NSManagedObject *mo = …; //Managed object that matches
10. the incoming JSON structure
11. //update MO with data from the dictionary
12. }
13. NSError *error = nil;
14. if (![private save:&error]) {
15. NSLog(@"Error saving context: %@\n%@",
16. [error localizedDescription], [error userInfo]);
17. abort();
18. }
19. [moc performBlockAndWait:^{
20. NSError *error = nil;
21. if (![moc save:&error]) {
22. NSLog(@"Error saving context: %@\n%@", [error localizedDescription], [error userInfo]);
23. abort();
24. }
25. }];
26. }];

SWIFT

1. let jsonArray = … //JSON data to be imported into Core Data
2. let moc = … //Our primary context on the main queue
4. let privateMOC = NSManagedObjectContext(concurrencyType: .PrivateQueueConcurrencyType)
5. privateMOC.parentContext = moc
7. privateMOC.performBlock {
8. for jsonObject in jsonArray {
9. let mo = … //Managed object that matches the incoming JSON structure
10. //update MO with data from the dictionary
11. }
12. do {
13. try privateMOC.save()
14. moc.performBlockAndWait {
15. do {
16. try moc.save()
17. } catch {
18. fatalError("Failure to save context: \(error)")
19. }
20. }
21. } catch {
22. fatalError("Failure to save context: \(error)")
23. }
24. }

In this example an array of data has been originally received as a JSON payload. You then create a new NSManagedObjectContext that is defined as a private queue. The new context is set as a child of the main queue context that runs the application. From there you call performBlock: and do the actual NSManagedObject creation inside of the block that is passed to performBlock:. Once all of the data has been consumed and turned into NSManagedObject instances, you call save on the private context, which moves all of the changes into the main queue context without blocking the main queue.

Passing References Between Queues

NSManagedObject instances are not intended to be passed between queues. Doing so can result in corruption of the data and termination of the application. When it is necessary to hand off a managed object reference from one queue to another, it must be done through NSManagedObjectID instances.

You retrieve the managed object ID of a managed object by calling the objectID method on the NSManagedObject instance.