objective-c - 超时后未触发 dispatch_semaphore_wait

Question

我想构建一个 NSOperation，它在开始后有 10 秒的超时时间，并且可以在事件的任何时候由另一个线程结束。我还使用 NSOperationQueue 来管理更多这样的操作，它一次只能计算一个(maxConcurrentOperationCount = 1)。为此，我考虑了一个使用 dispatch_semaphore 的实现，如下所示:

@implementation CustomOperation

dispatch_semaphore_t semaphore;
-(void) main {
    @autoreleasepool {

        [[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(shouldFinishWaiting:) name:@"myCustomEvent" object:nil];

        semaphore = dispatch_semaphore_create(0);

        [self doStuff];

        dispatch_semaphore_wait(semaphore, dispatch_time(DISPATCH_TIME_NOW, (int64_t)(10 * NSEC_PER_SEC)));
        [[NSNotificationCenter defaultCenter] removeObserver:self name:@"myCustomEvent" object:nil];
    }
}


-(void) shouldFinishWaiting {
    NSLog(@"[WatchOperation]: Should finish waiting! %@", self);
    dispatch_semaphore_signal(semaphore);
}

@end

我遇到的问题是，有很多次当用户启动应用程序时，第一个操作直到事件被触发才完成(这可能在 30 分钟后发生)。不会考虑超时。我在一些用户的日志中注意到了这一点，所以我无法重现它。可能出现什么问题导致 dispatch_semaphore_wait 无法执行？

后来编辑:我误以为 -doStuff 是异步的。好像不是，我换成:

dispatch_async(dispatch_get_global_queue(QOS_CLASS_USER_INITIATED, 0), ^{ 
    [self doStuff]; 
});

，但操作已经在“用户启动”的串行队列中。如我所见，它创建了另一个并发线程，每次都会发生吗？这样安全吗？

Answer 1

我认为调度信号量不会出错。也许您的 -doStuff 花费了太多时间。确保您正在执行以下操作:
1. [self doStuff];<​​ 方法是异步的，它分派(dispatch)到与当前线程不同的线程(如果您想要使用信号量的 10 秒超时，则分派(dispatch)到当前线程实际上没有意义).
2. 确保在 -doStuff 中不断检查 self.isCancelled。

此外，我建议您针对您的要求采用稍微不同的设计方法(如果我理解正确的话)——
1. 你的 NSOperation 总是可以从任何外部线程取消我对对象的调用取消，所以不需要复杂的基于 NSNotification 的方法，只需检查 isCancelled 并覆盖 -cancel 方法。
2. 对于 10 秒超时，您可以使用信号量方法，但只需让一个不同的线程执行信号量等待。该线程可以在 10 秒后取消您的任务。