Objective-C 等待异步操作和排队完成处理程序

Question

我必须计算一个昂贵的价值。计算完这个值后，我想运行一个完成处理程序块：

-(void) performCostlyCalculationWithCompletionHandler:(void (^)(void)complete 
{
    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
        id result = [self costlyCalculation];
        dispatch_async(dispatch_get_main_queue(), ^{
            complete(result);
        });
    });
}

相当标准。

现在，我希望能够重复调用此函数，而无需重新排队 costlyCalculation。如果costlyCalculation 已经在运行，我只想保存完成块并在costlyCalculation 完成后使用相同的result 调用它们。

有没有一种简单的方法可以用 GCD 或 NSOperationQueue 做到这一点？还是我应该将完成块存储在NSArray 中并自己调用它们？如果我这样做，我需要在这个数组周围放置什么样的同步？

更新

我可以接近dispatch_group_notify。基本上，我可以将工作块排入队列并将所有完成处理程序排入队列以在组之后运行：

dispatch_group_t group = dispatch_group_create();

dispatch_queue_t queue = dispatch_get_global_queue(0, 0);
dispatch_group_async(group, queue, ^(){
    // Do something that takes a while
    id result = [self costlyCalculation];
    dispatch_group_async(group, dispatch_get_main_queue(), ^(){
        self.result = result;
    });
});

dispatch_group_notify(group, dispatch_get_main_queue(), ^(){
    complete(result);
});

这可行，但我如何判断costlyCalcuation 是否已经在运行，并且如果我不需要的话，不将工作排入队列？

Answer 1

我认为您已经基本解决了这个问题。我刚刚想出了一个使用 NSOperationQueue 和 NSOperations 之间的依赖关系的替代方案。这是我认为的伪代码。

// somewhere, create operation queue
NSOperationQueue *opQueue = [[NSOperationQueue alloc] init];

-(void)tryCalculation:(CompletionBlockType)completionBlock
{
    if(opQueue.operationCount > 0)
    {
        NSOperation *op = [[NSOperation alloc] init];
        op.completionBlock = completionBlock;
        // you can control how to synchronize completion blocks by changing dependency object. In this example, all operation will be triggered at once when costly calculation finishes
        [op addDependency:[opQueue.operations firstObject]];
        [opQueue addOperation:op];
    }
    else
    {
        NSInvocationOperation *op = [[NSInvocationOperation alloc] initWithTarget:self selector:@selector(costlyCalculation) object:nil];
        op.completionBlock = completionBlock;
        [opQueue addOperation:op];
    }
}

仍然可能存在微妙的时间问题。也许我们可以在 costlyCalculation 函数中使用额外的标志。