如何检查 NSOperationQueue 是否完成以及是否有操作失败？

Question

我正在尝试在后台解析一些 XML 文件，以便 UI 不会冻结。我必须检查两件事：

• NSOperationQueue 完成了吗？
• NSOperation - 解析失败？

我有一个类，它是 NSOperation 的子类，如果解析失败，就会调用一个委托。队列中的操作仅限于同时进行一项。

我的问题是，我不能依赖在收到队列完成消息之前执行失败消息的事实。有时，在收到完成的消息之前，我不会收到失败的消息。然后，例如，我有这样的命令：

操作 1 成功 操作2成功 操作队列完成 操作 3 失败

所有消息都发送到主线程。收到完成的消息后，我想继续编写代码，但前提是所有操作都成功。如何处理队列完成后调用委托消息的问题。

这是我的代码的一些部分：

//XMLOperation.m
- (void)main {    
    NSLog(@"Operation started");

    if ([self parseXML]) {
            [self performSelectorOnMainThread:@selector(finishedXMLParsing) withObject:nil waitUntilDone:NO];
        } else {
            [self performSelectorOnMainThread:@selector(failedXMLParsing) withObject:nil waitUntilDone:NO];
        }
    }
    NSLog(@"Operation finished");
}


//StartController.m
[self.xmlParseQueue addObserver:self forKeyPath:@"operations" options:0 context:NULL];

...

- (void) observeValueForKeyPath:(NSString *)keyPath ofObject:(id)object 
                         change:(NSDictionary *)change context:(void *)context
{
    if (object == self.xmlParseQueue && [keyPath isEqualToString:@"operations"]) {
        if ([self.xmlParseQueue.operations count] == 0) {
            // Do something here when your queue has completed
            NSLog(@"queue has completed");
        }
    }
    else {
        [super observeValueForKeyPath:keyPath ofObject:object 
                               change:change context:context];
    }
}

Answer 1

发生这种情况的原因可能是，队列的操作属性的 KVO 通知不一定在主线程上传递，而已完成/失败的通知则在主线程上传递。

您应该确保完成通知也在主线程上执行，以便定义通知的顺序。

Answer 2

继续这个问题并将我的代码解决方案粘贴到此处。

void RunInMainThread(void (^block)(void))
{
    if (!block) {
        return;
    }

    if ([NSThread isMainThread]) {
        block();
    } else {
        dispatch_async(dispatch_get_main_queue(), block);
    }
}

@interface MyOperationQueue : NSOperationQueue

@property (nonatomic, assign) NSUInteger totalCount;
@property (nonatomic, copy) dispatch_block_t allOperationCompletionBlock;

@end

@implementation MyOperationQueue

- (void)addOperation:(NSOperation *)op
{
    [super addOperation:op];
    __weak typeof(self) weakSelf = self;

    self.totalCount++;
    DDLogVerbose(@"Added a operation, total: %ld operation(s).", self.totalCount);

    op.completionBlock = ^ {
        weakSelf.totalCount--;
        DDLogVerbose(@"Finished a operation, left: %ld operation(s).", weakSelf.totalCount);

        if (weakSelf.totalCount == 0) {
            if (weakSelf.allOperationCompletionBlock) {
                RunInMainThread(weakSelf.allOperationCompletionBlock);
            }
        }
    };
}

@结尾