GCD 串行队列和竞争条件

Question

我有两种在串行队列上运行的方法。每个方法都返回某个类的副本。我正在尝试实现线程安全解决方案，同时保持数据完整性。

例如：

-(Users *) getAllUsers
{ 
       __block copiedUsers;
       dispatch_sync(_backgroundQueue, ^{
            copiedUsers = [self.users copy]; // return copy object to calling thread.  
       });
       return copiedUsers;
}

-(Orders *) getAllOrders
{ 
       __block copiedOrders;
       dispatch_sync(_backgroundQueue, ^{
            copiedOrders = [self.Orders copy]; // return copy object to calling thread.
       });
       return copiedOrders;
}

除了这两种方法之外，我还有一个添加/删除用户和订单的工作类，所有这些都通过串行队列backgroundQueue 完成。

如果在主线程中我调用getAllUsers，然后在另一个之后调用getAllOrders，我的数据完整性是不安全的，因为在这两个调用之间工作类可能已经改变了模型。

我的问题是如何为调用者提供一个允许多个方法以原子方式运行的良好接口？

Answer 1

模型仅从backgroundQueue 串行队列更新。 客户端通过接收在后台队列中运行的块的方法与模型对话。

另外，为了不冻结主线程，我创建了另一个队列并运行了一个与网关方法对话的块。

P.S - 注意 dispatch_sync 仅在 runBlockAndGetNeededDataSafely 中调用以避免死锁。

代码示例：

aViewController.m

ManagerClass *m = [ManagerClass new];    
dispatch_queue_t q = dispatch_queue_create("funnelQueue", DISPATCH_QUEUE_SERIAL);
dispatch_block_t block_q = ^{
    __Users *users;
    __Orders *orders;
    [manager runBlockAndGetNeededDataSafely:^
     {
            users  = [manager getUsers];
            orders = [manager getOrders];
           dispatch_async(dispatch_get_main_queue(),
          ^{
               // got data safely - no thread issues, copied objects. update UI!
               [self refreshViewWithUsers:users 
                                  orders:orders];
           });
     }];
}
dispatch_async(q, block_q);

Manager.m 实现：

-(void) runBlockInBackground:(dispatch_block_t) block
{
    dispatch_sync(self.backgroundQueue, block); 
}
 -(Users *) getAllUsers
 { 
       return [self.users copy];
 }

 -(Orders *) getAllOrders
 {  
       return [self.Orders copy];
 }

Answer 2

要回答有关如何检查当前队列的问题： 首先，当你创建队列时，给它一个标签：

static void* queueTag = &queueTag;
dispatch_queue_t queue = dispatch_queue_create("a queue", 0);
dispatch_queue_set_specific(queue, queueTag, queueTag, NULL);

然后像这样运行一个块：

-(void)runBlock:(void(^)()) block
{
    if (dispatch_get_specific(queueTag) != NULL) {
        block();
    }else {
        dispatch_async(self.queue, block);
    }
}

Answer 3

您的示例不起作用。我建议使用完成回调。您应该可以选择知道工人何时完成工作以恢复价值。

- (void)waitForCompletion:(BOOL*)conditions length:(int)len timeOut:(NSInteger)timeoutSecs {
    NSDate *timeoutDate = [NSDate dateWithTimeIntervalSinceNow:timeoutSecs];
    BOOL done = YES;
    for (int i = 0; i < len; i++) {
        done = done & *(conditions+i);
    }
    do {
        [[NSRunLoop currentRunLoop] runMode:NSDefaultRunLoopMode beforeDate:timeoutDate];
        if([timeoutDate timeIntervalSinceNow] < 0.0)
            break;

        //update done
        done = YES;
        for (int i = 0; i < len; i++) {
            done = done & *(conditions+i);
        }
    } while (!done);
}


-(void) getAllUsers:(void(^)(User* user, NSError* error))completion
{
    dispatch_async(_backgroundQueue, ^{
        BOOL condition[2] = [self.userCondition, self.orderCondition];
        [self waitForCompletion: &condition[0] length:2 timeOut:60];
        if (completion) {
            completion([self.users copy], nil);
        }
    });
}