在依赖于它们的 NSOperation 对象中处理从多个 NSOperation 对象返回的数据

Question

我正在编写一个连接 Web 的应用程序，该应用程序需要执行多个异步请求来加载依赖关系树下部所需的数据。

图 1.

---

出于可视化目的，请考虑 ASIHTTPRequests A、B、C、D、E 和 F 的示例：

A 的 url 取决于 B 和 C 的结果，

B 的 url 取决于结果D、E 和 F 的值。B

和 C 可以同时计算，D、E 和 F 也可以同时计算。

NSOperationQueue = [(D,E,F),(B,C),A]

---

到目前为止，我有创建了一个NSOperationQueue 包含 ASIHTTPRequest 的依赖树。然而，ASIHTTPRequests 的 URL 应该依赖于之前操作的结果，但现在它们并不依赖于。

问题：将多个 NSOperation 执行的计算结果传递给依赖于它们的 NSOperation 的最佳方法是什么，以及如何使用 ASIHTTPRequests 进行设置？

提前致谢， 朱利安·塞佩克

Answer 1

我会做以下事情。

首先，队列：

D、E、F 和 C

在 D、E 和 C 的 requestFinished 委托回调中F，检查其他所有3个请求是否已完成，如果是则发送B。

对B和B的回调执行相同的操作C - 如果它们都完成了，则发送 A。

您需要某种由所有请求共享的对象来存储早期请求的结果/状态。

Answer 2

我最终通过将 ASIHTTPRequest 包装在自定义 NSOperation 对象中来解决此问题，该对象以自定义请求 B 包含指向 D、E 和 F 的 ASIHTTPRequest UserInfo 字典中对象的指针的方式填充请求。虽然我喜欢 @JosephH 的解决方案，但我无法弄清楚如何轻松生成具有完整依赖关系树的字典或数组。

下面提供了我的自定义 NSOperationObject 的简化版本；欢迎任何建议。我使用了 Apple 的并发编程指南 广泛作为参考，但因为我之前没有任何扩展 NSOperation 的经验类，我确信有更好的方法来做到这一点。

#import <Foundation/Foundation.h>
#import "SyncableData.h"
#import "ASIHTTPRequest.h"

@interface PushContentRequest : NSOperation <ASIHTTPRequestDelegate> {
    BOOL executing;
    BOOL finished;
    id <SyncableData> data;
    ASIHTTPRequest *request;
    NSURL *url;
    id <ASIHTTPRequestDelegate> delegate;
}

- (id)initWithDataObject:(id <SyncableData>)theData url:(NSURL *)theUrl delegate:(id <ASIHTTPRequestDelegate>)theDelegate;

@end


#import "PushContentRequest.h"

@implementation PushContentRequest

- (id)initWithDataObject:(id <SyncableData>)theData url:(NSURL *)theUrl delegate:(id <ASIHTTPRequestDelegate>)theDelegate {
    if ((self = [super init])) {
        executing = NO;
        finished = NO;
        data = [theData retain];
        url = [theUrl retain];
        delegate = [theDelegate retain];
    }
    return self;
}

- (BOOL)isConcurrent {
    return YES;
}

- (BOOL)isExecuting {
    return executing;
}

- (BOOL)isFinished {
    return finished;
}

- (void)start {
    if ([self isCancelled]) {
        [self willChangeValueForKey:@"isFinished"];
        finished = YES;
        [self didChangeValueForKey:@"isFinished"];
        return;
    }

    NSAutoreleasePool* pool = [[NSAutoreleasePool alloc] init];
    request = [ASIHTTPRequest requestWithURL:url];
    NSString *xmlToPost = [[NSString alloc] initWithString: [theData getXMLRep]];
    [request appendPostData:[xmlToPost dataUsingEncoding:NSUTF8StringEncoding]];
    [request setDelegate:self];
    NSDictionary *userInfoDict = [[NSDictionary alloc] initWithObjectsAndKeys:data, @"theData", nil];
    [request setUserInfo:userInfoDict];
    [userInfoDict release];
    [xmlToPost release];
    [self willChangeValueForKey:@"isExecuting"];
    [request start];
    executing = YES;
    [self didChangeValueForKey:@"isExecuting"];
    [pool release];

}

- (void)dealloc {
    [delegate release];
    [url release];
    [data release];
    [super dealloc];
}

- (void)requestFinished:(ASIHTTPRequest *)therequest {
    [delegate requestFinished:therequest];

    [self willChangeValueForKey:@"isFinished"];
    [self willChangeValueForKey:@"isExecuting"];

    executing = NO;
    finished = YES;

    [self didChangeValueForKey:@"isExecuting"];
    [self didChangeValueForKey:@"isFinished"];
}

- (void)requestFailed:(ASIHTTPRequest *)therequest {
    [delegate requestFailed:therequest];
    [self willChangeValueForKey:@"isFinished"];
    [self willChangeValueForKey:@"isExecuting"];

    executing = NO;
    finished = YES;

    [self didChangeValueForKey:@"isExecuting"];
    [self didChangeValueForKey:@"isFinished"];
}

@end

此 PushContentRequest 的委托当前处理 ASIHTTPRequest 的 UserInfo 字典的解释和我的实现中的请求，尽管我认为在 PushContentRequest 的主体中进行此处理可能更有意义。