NSBlockOperation,NSOperationQueue和Blocks

dpi*_*uto 5 objective-c nsoperationqueue ios objective-c-blocks nsblockoperation

我必须从RestAPI中同步一堆信息.我必须做6次RestAPI调用才能完成工作.我用Blocks设计了API调用,如果有的话,返回NSError.这些调用中的3个应该执行嵌套,因为第一个调用向其他调用提供信息并允许执行,而其他3个调用可以独立运行.由于提高了网络性能,我将同步调用设计如下:

  • 1个NSBlockOperation,包含第一个嵌套的3个块;
  • 1个包含其他三个块的NSBlockOperation;
  • 1 NSBlockOperation,我用作"semphore",并告诉我完成所有工作.

最后一个NSBlockOperation依赖于前两个NSBlockOperation.

我还有一个NSOperationQueue,它包含所有三个NSBlockOperation,其中信号量NSBlockOperation作为队列中的最后一个添加.我要实现的结果是:前两个块名为Concurrently,当它们的工作完成时,调用信号量NSBlockOperation并将控件返回给提供UIAlertMessage的用户.

结果不是之前解释的:返回控件而不等待syncAllBlocksInformation块的结束.

在包含NSBlockOperation的代码下面:

-(void)syncAllBlocksInformation:(void(^)(NSError *error))completion{

__block NSError *blockError = nil;

NSOperation *syncUserInfoOperation = [NSBlockOperation blockOperationWithBlock:^{
    [dataSync syncUserInfo:tfMail.text password:tfPassword.text completion:^(NSError *error, NSNumber *idUser) {
        if(!error){
            [dataSync syncUserfilesInfo:idUser completion:^(NSError *error) {
                if(!error){
                    [dataSync syncUserBookings:^(NSError *error) {
                        if(error){
                            blockError = error;
                        }
                    }];
                }
                else{
                    blockError = error;
                }
            }];

        }
        else{
            blockError = error;
        }
    }];
}];



NSBlockOperation *otherSyncOperations = [NSBlockOperation blockOperationWithBlock:^{
    [dataSync syncNewsInfo:^(NSError *error) {
        if(error){
            blockError = error;
            NSLog(@"error %@",error);
        }
    }];

}];

[otherSyncOperations addExecutionBlock:^{
    [dataSync syncLocationsInfo:^(NSError *error) {
        if(error){
            blockError = error;
            NSLog(@"error %@",error);
        }
    }];

}];

[otherSyncOperations addExecutionBlock:^{
    [dataSync syncExoticAnimalTypesAndAnimals:^(NSError *error) {
        if(error){
            blockError = error;
            NSLog(@"error %@",error);
        }
    }];
}];


NSOperation *completionOperation = [NSBlockOperation blockOperationWithBlock:^{
    NSLog(@"END");
}];

[completionOperation setCompletionBlock:^{
    NSLog(@"Syc isEx %i",syncUserInfoOperation.isExecuting);
    NSLog(@"other isEx %i",otherSyncOperations.isExecuting);
    completion(blockError);
}];

NSOperationQueue *opQueue = [NSOperationQueue new];

[completionOperation addDependency:syncUserInfoOperation];
[completionOperation addDependency:otherSyncOperations];

[opQueue addOperation:syncUserInfoOperation];
[opQueue addOperation:otherSyncOperations];
[opQueue addOperation:completionOperation];

}
Run Code Online (Sandbox Code Playgroud)

在这里,调用上面的代码:

-(IBAction)login:(id)sender{

[self dismissKeyboardOpened:nil];

hud=[MBProgressHUD showHUDAddedTo:self.view animated:YES];
[hud setLabelText:NSLocalizedString(@"login_hud_message", login_hud_message )];
[hud setMode:MBProgressHUDModeIndeterminate];

[self showHudAndNetworkActivity:YES];

[self syncAllBlocksInformation:^(NSError *error) {

    [self showHudAndNetworkActivity:NO];

    if(!error){
        NSLog(@"End LOGIN");
        [self showAlert:@"Login" message:@"Login OK" dismiss:YES];
    }
    else{
        [self showAlert:@"Error" message:@"Login NO" dismiss:NO];
    }

}];
}
Run Code Online (Sandbox Code Playgroud)

怎么了 ?

Mik*_*e S 5

问题是,NSBlockOperation同步块。它将finished在其块完成执行后立即执行。如果其块触发了异步方法,则这些方法将独立运行。

例如,当syncUserInfoOperation执行您的代码块时,它会触发[dataSync syncUserInfo:...],然后认为自己已完成;它不等待任何完成处理程序触发,或类似的事情。

一个好的解决方案是创建自己的NSOperation子类。您可能想为每种数据同步类型创建一个,以便更轻松地设置依赖关系等,但这取决于您。您可以在此处阅读有关如何执行操作的所有信息(请务必阅读“ 配置并发执行的操作 ”部分)。

您还可以创建一个通用NSOperation子类,该子类带有一个可以异步运行的块。这样做的主要问题是,它可能使您更难处理诸如取消操作之类的事情。