【问题标题】:Abort all dispatch_semaphore_wait中止所有 dispatch_semaphore_wait
【发布时间】:2015-03-27 13:55:39
【问题描述】:

在 iOS 中,GCD 提供信号量来同步对有限资源的访问。

在我的程序中,我正在从外部设备读取数据。该外部设备可以断开连接,并且程序将永远不会再次向信号量发出信号。所以我们最终会遇到以下情况:

  • 线程 1 正在等待信号量

    if (dispatch_semaphore_wait(self.writeSem, /* 15s timeout */)) {
    
  • 线程 2 知道没有等待会成功

最终,dispatch_semaphore_wait 超时,返回NO,线程 1 恢复运行。

我怎样才能立即让这个dispatch_semaphore_wait 失败,所以线程1 会立即得到NO 并继续他的生活?我可以使用某种“取消信号量”吗?

【问题讨论】:

  • 您显然可以 (a) 设置一些状态变量来指示它已被取消,然后 (b) 在该信号量上发布一个信号。
  • 这有可能通过读取/写入该状态变量来创建竞争条件。这几乎就是条件变量存在的理由。

标签: ios multithreading grand-central-dispatch semaphore


【解决方案1】:

如果没有额外的“机器”,信号量是错误的抽象。除了发出信号外,没有“取消信号量等待”操作,当发出信号时,没有更多信息,你不知道它是因为成功还是终止而发出信号。因此,您可以添加一个外部标志来指示信号是用于完成还是提前终止,但是您必须适当地保护该标志以防止并发读取和写入。

这里使用的规范原语是条件变量,标准 Cocoa 示例将使用 NSCondition。一个简单的例子可能如下所示:

NSCondition* cond = [NSCondition new];
__block BOOL workSucceeded = NO;
__block BOOL subordinateFinished = NO;
NSTimeInterval timeout = 5.0;

// Waiter
dispatch_async(dispatch_get_global_queue(0, 0), ^{
    [cond lock];
    while (!subordinateFinished)
    {
        if (![cond waitUntilDate: [NSDate dateWithTimeIntervalSinceNow: timeout]])
        {
            // Timed out...
            NSLog(@"Timed out waiting for work at: %@", [NSDate date]);
            break; // don't keep waiting
        }
        else if (workSucceeded)
        {
            // Signaled to indicate that work was done
            NSLog(@"Work finished at: %@", [NSDate date]);
        }
        else //if (!workSucceeded)
        {
            // Signaled to indicate premature termination.
            NSLog(@"Work prematurely terminated at: %@", [NSDate date]);
        }
    }
    [cond unlock];
});

// Actor
dispatch_async(dispatch_get_global_queue(0, 0), ^{
    NSLog(@"Work started at: %@", [NSDate date]);
    BOOL completed = NO;

    // Uncomment one of these to trigger each case
    // Finish on time:
    //sleep(1);
    //completed = YES;

    // Fail Early:
    //sleep(1);

    // Time out
    //sleep(timeout + 1);

    // ... and when done
    [cond lock];
    workSucceeded = completed;
    subordinateFinished = YES;
    [cond signal];
    [cond unlock];
});

这里要理解的重要一点是workSucceededsubordinateFinished 受到条件锁的保护,任何不持有锁的人都不会读取或写入。人们在第一次使用 NSCondition 时通常不清楚的是,调用 -wait-waitUntilDate:-signal 的行为都会导致调用线程暂时放弃锁,而了解当在该线程上恢复执行时,它将再次持有锁。

希望这会有所帮助。

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 2014-10-21
    • 1970-01-01
    • 1970-01-01
    • 2018-05-28
    • 2012-07-21
    • 1970-01-01
    • 2019-11-30
    相关资源
    最近更新 更多