我想构建一个 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];
});
,但操作已经在“用户启动”的串行队列中。如我所见,它创建了另一个并发线程,每次都会发生吗?这样安全吗?
最佳答案
我认为调度信号量不会出错。也许您的 -doStuff 花费了太多时间。确保您正在执行以下操作:
1. [self doStuff];<
方法是异步的,它分派(dispatch)到与当前线程不同的线程(如果您想要使用信号量的 10 秒超时,则分派(dispatch)到当前线程实际上没有意义).
2. 确保在 -doStuff 中不断检查 self.isCancelled。
此外,我建议您针对您的要求采用稍微不同的设计方法(如果我理解正确的话)——
1. 你的 NSOperation 总是可以从任何外部线程取消我对对象的调用取消,所以不需要复杂的基于 NSNotification 的方法,只需检查 isCancelled 并覆盖 -cancel 方法。
2. 对于 10 秒超时,您可以使用信号量方法,但只需让一个不同的线程执行信号量等待。该线程可以在 10 秒后取消您的任务。
关于objective-c - 超时后未触发 dispatch_semaphore_wait,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/31728024/