iOS:在 while 循环中使用 block 回调的异步方法

Question

我有以下要求:

给定分层树状结构，我正在执行 breadth-first-search遍历整个数据集。数据由 API 使用一种方法提供:(使用 AFNetworking 向服务器发出请求，将结果保存到核心数据，并在成功时使用存储的条目回调完成 block )

-(void) getChildrenForNodeId:(NSNumber*)nodeId
完成:(void (^)(NSArray *nodes))completionBlock;

Controller 执行以获取数据的方法:

 -(void)getAllNodesWithCompletion:(void (^)(NSArray *nodes))completionBlock{

     NSNumber *rootId = ...

     [MyNetworkManager getChildrenForNodeId:rootId completion:^(NSArray *nodes){

        for(Node *node in nodes){

             [self iterateOverNode:node.nodeId];

        }

       //execute completionBlock with nodes fetched from database that contain all their children until the very last leaf

     }];

  }

问题是:

-(void)iterateOverNode:(NSNumber*)nodeId {

    NSMutableArray *elements = [NSMutableArray array];

    [elements addObject:nodeId];

    while ([elements count]) {

        NSNumber *current = [elements objectAtIndex:0];

        [MyNetworkManager getChildrenForNodeWithId:current completion:^(NSArray *nodes) {

              /**
                In order to continue with the loop the elements array must be updated. This can only happen once we have retrieved the children of the current node. 
However since this is in a loop, all of these requests will be sent off at the same time, thus unable to properly keep looping. 
          */
          for(Node *node in nodes){
              [elements addObject:node.nodeId];
          }

          [elements removeObjectAtIndex:0];

        }];

    }

}

基本上我需要回调的结果来控制 while 循环的流程，但我不确定如何实现它。我的理解是，从 while-loop 中对 getChildrenForNodeWithId:completion: 的请求应该在一个新线程中以串行顺序发生，以便另一个应该在第一个线程之后开始已经完成。我不确定如何使用 NSOperation 或 GCD 来实现这一点。任何帮助将不胜感激。

Answer 1

这里你需要的是一些递归。这个问题很棘手，因为我们还需要一种方法来跟踪和检测我们已经探索到叶节点的每个分支的点。

我不是树搜索算法方面的专家，所以有些人可能会改进我在这里的回答。通过使用根节点 ID 调用它来启动它。 self.trackingArray 是一个带有 __block 限定符的 NSMutableArray 属性。每次我们开始请求一个节点时，我们将它的 nodeId 添加到这个数组中，当它返回时，我们删除它的 nodeId，并添加它的子节点的 nodeId。然后我们可以知道，当跟踪数组的计数达到0时，所有发出的请求都已返回，并且没有将子id添加到数组中。检测到我们完成后，您可以调用已保存的 block 或委托(delegate)方法。

此解决方案不包含任何错误处理。如果任何请求失败，则不会重试，所有子节点都将被忽略。

- (void)getNodesRecursively:(NSNumber *)nodeId {

    // Only do this once
    if (self.trackingArray == nil) {
        self.trackingArray = [NSMutableArray new];
        [self.trackingArray addObject:nodeId];
    }
    __weak typeof(self) weakSelf = self;

    [MyNetworkManager getChildrenForNodeWithId:nodeId completion:^(NSArray *nodes) {

        [self.trackingArray removeObject:nodeId];

        for (Node *node in nodes) {

            [weakSelf.trackingArray addObject:node.nodeId];
            [weakSelf getNodesRecursively:node.nodeId];
        }

        if (weakSelf.trackingArray.count == 0) {
            // We are done.
            // Reset the state of the trackingArray
            self.trackingArray = nil;

            // call a method here to notify who ever needs to know.
            [weakSelf allNodesComplete];
        }

    }];
}

你的其他方法看起来像这样

-(void)getAllNodesWithCompletion:(void (^)(NSArray *nodes))completionBlock{

     // Save the block to a property 
     self.completion = completionBlock;

     // Call -getNodesRecursively with root id
     [self getNodesRecursively:rootNodeId];
}

那么你可以有第二种方法

- (void)allNodesComplete {

      // Call saved block
      // Completion should load nodes from core data as needed
      self.completion();
}

我还没有测试过代码，但这种方法看起来合理吗？我假设我们不需要捕获此处的节点，因为它们可以根据需要从核心数据中加载。