ios - NSBlockOperation、NSOperationQueue 和 block

Question

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

• 1 个包含前 3 个嵌套 block 的 NSBlockOperation；
• 1 个包含其他三个 block 的 NSBlockOperation；
• 1 个 NSBlockOperation，我用作“信号量”并在所有工作完成时告诉我。

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

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

结果与之前解释的不同:无需等待 syncAllBlocksInformation block 结束即可返回控件。

在包含 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];

}

在这里，调用上面 block 的代码:

-(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];
    }

}];
}

怎么了？

Answer 1

问题是 NSBlockOperation 用于同步 block 。一旦其 block 执行完毕，它将完成。 如果它的 block 触发异步方法，那些将独立运行。

例如，当您的syncUserInfoOperation block 被执行时，它触发[dataSync syncUserInfo:...] 然后认为自己完成了；它不会等待任何完成处理程序触发或类似的事情。

一个好的解决方案是创建您自己的 NSOperation 子类。您可能希望为每种数据同步类型创建一个，以便更轻松地设置依赖项等，但这取决于您。您可以阅读所有关于如何做到这一点的信息 here (请务必阅读“Configuring Operations for Concurrent Execution ”部分)。

您还可以制作一个通用的 NSOperation 子类，它采用可以异步运行的 block 。这样做的主要问题是它使处理诸如取消操作之类的事情变得更加困难，而您可能仍然想要这样做。