如何在回调块中异步地创建FetchRequest

Question

有人知道如何在第一个异步通信的完成块中启动另一个新的异步方法的最佳实践吗？

我正在测试代码，以在Facebook的另一个异步通信的完成回调中异步调用NSFetchRequest（因为STACKMOB iOS SDK在内部与服务器同步）。代码执行在NSFetchRequest的行突然终止。我意识到它不能正确工作的原因之一。

我猜想完成块一旦调用[managedObjectContext executeFetchRequest:fetchRequest error:&error]，就已经从内存中释放了。

但我不知道更好的解决方案来解决这个问题。感谢任何帮助。

SDK使用：

• (void)queueRequest:(NSURLRequest *)request options:(SMRequestOptions *)options onSuccess:(SMFullResponseSuccessBlock)onSuccess onFailure:(SMFullResponseFailureBlock)onFailure

https://github.com/stackmob/stackmob-ios-sdk/blob/master/Classes/SMDataStore%2BProtected.m

我尝试过：

• 如何等待异步分派的块完成？

• NSURLConnection sendAsynchronousRequest:queue:completionHandler: 连续发出多个请求？

• 如何从完成块中检索返回值？

• Objective-C中的块递归

:

- (IBAction)checkFacebookInfo:(id)sender
{
    //completion block of facebook info
    void(^onCompleteBlock)(NSDictionary*) = [[^(NSDictionary* userInfo)
    {
        NSManagedObjectContext *managedObjectContext = nil;
        managedObjectContext = [[SingletonCoreData sharedManager] managedObjectContext];

        NSFetchRequest *fetchRequest = [[NSFetchRequest alloc] initWithEntityName:@"User"];

        //for STACKMOB, customized NSFetchRequest internally sync to the server. It is Asynchronous method.
        NSArray *results = [managedObjectContext executeFetchRequest:fetchRequest error:&error];// failed

        //Not reached here
        //set userInfo to results here

    } copy] autorelease];

    //invoke onCompleteBlock after executing asynchronously, client(SMClient object for STACKMOB)
    [client getLoggedInUserFacebookInfoWithOnSuccess:onCompleteBlock onFailure:^(NSError *error)
     {

         NSLog(@"No user found");

     }];

}

编辑： 我尝试了下面所写的内容，然后它成功运行。但是我感觉它很慢。我将代码的一部分放入“dispatch_async”块中。我正在等待任何其他更好的解决方案。

    - (IBAction)checkFacebookInfo:(id)sender
    {
        //completion block of facebook info
        void(^onCompleteBlock)(NSDictionary*) = ^(NSDictionary* userInfo)
        {

            dispatch_queue_t gQueue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);

            dispatch_async(gQueue, ^{
                NSManagedObjectContext *managedObjectContext = nil;
                managedObjectContext = [[SingletonCoreData sharedManager] managedObjectContext];

                NSFetchRequest *fetchRequest = [[NSFetchRequest alloc] initWithEntityName:@"User"];

                //for STACKMOB, customized NSFetchRequest internally sync to the server. It is Asynchronous method.
                NSArray *results = [managedObjectContext executeFetchRequest:fetchRequest error:&error];// success

                //set userInfo to results here

            });

        };

        //invoke onCompleteBlock after executing asynchronously, client(SMClient object for STACKMOB)
        [client getLoggedInUserFacebookInfoWithOnSuccess:onCompleteBlock onFailure:^(NSError *error)
         {

             NSLog(@"No user found");

         }];

}

- wheel

---

你尝试过在alloc/init之后使用retain调用fetcheRequest，然后在使用后调用release吗？ - Yuliani Noriega

谢谢yulz，我试过了，但对我来说不起作用。 - wheel

首先，您不需要复制和自动释放该块。"问题可能是在NSFetchRequest完成之前释放了调用方块的内存" 什么？这个语句没有任何意义。 - user102008

Answer 1

如果您正在尝试同步多个异步操作（通过网络或其他方式），我强烈建议使用 Promises。关于 Promises 的一般介绍，最近 Los Techies 的一篇博客文章非常不错：

http://lostechies.com/derickbailey/2012/07/19/want-to-build-win8winjs-apps-you-need-to-understand-promises/

话虽如此，在iOS上有一个很好的库叫做KSPromise，我已经用了相当多了：https://github.com/kseebaldt/deferred

使用Promise，您可以在一个或多个异步调用完成后进行fetch请求。例如，join Promise只有在其所有依赖Promise也解决后才会被解决！我认为，如果您正在进行复杂的操作，使用Promise可以使您的代码更加有组织和易于阅读。

话虽如此，这里有一个相当牵强的例子，展示了使用Promise编写代码的可能方式（与Facebook iOS 3.1 SDK相比）：

- (IBAction)checkFacebookInfo:(FBSession *)session {
  KSDeferred *dfd = [KSDeferred defer];

  FBRequest *meRequest = [[FBRequest alloc] initWithSession:session graphPath:@"/me"];
  [meRequest startWithCompletionHandler:
    ^(FBRequestConnection *connection, NSDictionary<FBGraphUser> *user, NSError *error) {
      if (error) {
        [dfd.promise rejectWithError:error];
      } else {
        [dfd.promise resolveWithValue:user];
      }
  }];

  [dfd.promise whenResolved:^(KSPromise *p) {
    NSDictionary *userInfo = p.value;
    NSManagedObjectContext *managedObjectContext = [[SingletonCoreData sharedManager] managedObjectContext];
    NSFetchRequest *fetchRequest = [[NSFetchRequest alloc] initWithEntityName:@"User"];
    NSError *error;
    NSArray *results = [managedObjectContext executeFetchRequest:fetchRequest error:&error];
    // Do whatever with results and userInfo here
  }];

  [dfd.promise whenRejected:^(KSPromise *p) {
    NSError *e = (NSError *)p.value;
    NSLog(@"Error: %@", [e localizedDescription]);
  }];
}

最后一件事：在使用Core Data和dispatch_async时要非常小心。你可能会遇到各种难以调试的并发问题。

- David LaMacchia