Objective-C wait для асинхронных операций и обработчиков завершения очереди.

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); 
     }); 
    }); 
} 

Довольно стандартный.

Теперь, я хотел бы иметь возможность называть эту функцию повторно, без повторного enqueueing costlyCalculation. Если costlyCalculation уже работает, я хотел бы просто сохранить блокировки завершения и назвать их всех одним и тем же result после завершения costlyCalculation.

Есть ли простой способ сделать это с помощью GCD или NSOperationQueue? Или я должен просто хранить блоки завершения в NSArray и называть их сам? Если я это сделаю, какую синхронизацию мне нужно установить вокруг этого массива?

UPDATE

Я могу сблизиться с 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]; 
    } 
} 

Тем не менее, может возникнуть тонкая проблема с синхронизацией. Возможно, мы могли бы использовать дополнительный флаг в функции costCalculation.