objective-c - NSBlockOperation 的粒度状态

我扩展了 NSOperationQueue 以允许添加带有特定 NSBlockOperation 作为标识符的 NSString。

标识符值保存在用作注册表的 NSMutableArray 中。这就是我实现注册表的方式。

-(void)addOperation:(NSOperation *)operation withID:(NSString*)operationID
{
    @synchronized(self.queueReference)
    {
        [self.queueReference addObject:operationID]; // <-- just a mutable array
    }

    [operation setCompletionBlock:^(){
        @synchronized(self.queueReference) {
            [self.queueReference removeObject:operationID];
        }
    }];

    [self addOperation:operation];
}

基本上，我添加了一个完成块，它在特定操作完成后清理注册表。

但是，虽然这有效，但我需要向队列添加更多粒度。

我只将队列与块操作一起使用，并且在块的执行过程中，我可能会根据执行的方式向监听器发送不同的 NSNotification。

我试图实现的目标:

调用者尝试将带有标识符的特定 NSBlockOperation 添加到队列中。如果队列已经有这样的标识符就不要添加块，调用类将自己设置为监听器。

什么东西少了？仅检查标识符是不够的，可能会出现 NSBlockOperation 已经调度 NSNotification 但尚未调用完成块的情况。

所以调用者类询问队列，它说标识符存在于注册表中，并且调用者错误地设置自己以监听永远不会到达的通知，因为它已经被发送了。

相反的情况是:调用者询问队列，它说“标识符在注册表中”但发送了 NSNotification。调用者将 NSBlockOperation 放入队列。

注册表的检查是通过一种简单的方法进行的:

-(BOOL)hasOperationWithID:(NSString*)operationID
{
    @synchronized(self.queueReference)
    {
        return [self.queueReference containsObject:operationID];
    }
}

但在这一点上，我对如何扩展这种方法没有太多想法。我正在编写的代码有点“学术性”，它没有任何特定目的，只是我在尝试进行实验。因此我在代码中有很大的灵活性。但这对我来说是一个相当新的主题，所以请尽可能具体地说明建议实现的任何缺点。

最佳答案

看起来您当前的系统具有三个基本事件:

操作加入队列

操作在执行

时发送通知

操作完成块称为

除非队列本身显式监听可能由块发送的任何 NSNotifications，否则它无法知道它们是否已经发生。但即使它确实在监听，NSNotifications 的观察者被调用的顺序也是不确定的。换句话说，即使队列监听通知并将其回调与入队/出队操作互锁，对于另一个客户端开始监听该 NSNotification 仍然可能(并且最终会)为时已晚，并且您会错误地拒绝操作.

考虑这个替代方案:不要使用完成块来管理标识符列表，而是使用通知本身——让队列处理发送通知。换句话说，让我们摆脱第三个事件，让通知发送为标识符列表维护做双重任务。我想出的最简单的方法是:

标题:

//
//  SONotifyingOperationQueue.h
//  NotifyingOpQueue
//

typedef void (^SOSendNotificationBlock)(NSDictionary* userInfo);
typedef void (^SONotifyingBlock)(SOSendNotificationBlock sendNotificationBlock);

@interface SONotifyingOperationQueue : NSOperationQueue

- (BOOL)addOperationForBlock:(SONotifyingBlock)block withNotificationName:(NSString*)notificationName;

@end

执行

//
//  SONotifyingOperationQueue.m
//  NotifyingOpQueue
//

#import "SONotifyingOperationQueue.h"

@implementation SONotifyingOperationQueue
{
    NSMutableSet* _names;
}

- (BOOL)addOperationForBlock: (SONotifyingBlock)block withNotificationName: (NSString*)notificationName
{
    notificationName = [[notificationName copy] autorelease];

    BOOL shouldAdd = NO;
    @synchronized(self)
    {
        _names = _names ? : [[NSMutableSet alloc] init];

        if (![_names containsObject: notificationName])
        {
            [_names addObject: notificationName];
            shouldAdd = YES;
        }
    }

    if (shouldAdd)
    {
        NSBlockOperation* blockOp = [[[NSBlockOperation alloc] init] autorelease];

        __block SONotifyingOperationQueue* blockSelf = self;

        SOSendNotificationBlock notificationBlock = ^(NSDictionary* userInfo){
            @synchronized(blockSelf)
            {
                [blockSelf->_names removeObject: notificationName];
                // Sending the notification from inside the @synchronized makes it atomic
                // with respect to enqueue operations, meaning there can never be a missed
                // notification that could have been received.
                [[NSNotificationCenter defaultCenter] postNotificationName: notificationName object: blockSelf userInfo: userInfo];
            }
        };

        dispatch_block_t executionBlock = ^{
            block(notificationBlock);
        };

        [blockOp addExecutionBlock: executionBlock];
        [self addOperation: blockOp];
    }

    return shouldAdd;
}

- (void)dealloc
{
    [_names release];
    [super dealloc];
}

@end

此方法对您的原始方法进行了一些更改。首先，这里的 API 添加了块而不是 NSOperations 。你可以用 NSOperation 子类做同样的事情，但它会是更多的代码，并且不会改变整体模式。它还合并了标识符和通知名称的概念。如果一个操作可以发送多个不同的 NSNotifications ，如果不进行修改，这将无法工作，但同样，整体模式将是相同的。这种模式的重要特征是您的 id/name 检查现在与发送通知本身互锁，提供了强有力的保证，如果有人去向队列中添加一个新的块/操作，以及另一个具有相同 id/name 的操作还没有触发它的通知，新的操作不会被添加，但是如果通知已经被触发，那么它会被添加，即使前面的块还没有完成。

如果 NSOperation 对象在这里很重要，你也可以让这里的方法返回它为提供的块创建的操作。

哈。

关于objective-c - NSBlockOperation 的粒度状态，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/13950349/