并发队列问题非并发 NSOperations

Question

我有一个 NSOperationQueue，其中包含 2 个 NSOperations，并设置为通过将 setMaxConcurrentOperationCount 设置为 1 来依次执行它们。

其中一个操作是标准的非并发操作（只是一个 main） code> 方法），它同步从网络检索一些数据（当然是在单独的操作线程上）。另一个操作是并发操作，因为我需要使用一些必须异步运行的代码。

问题是我发现并发操作只有先添加到队列中才有效。如果它发生在任何非并发操作之后，那么奇怪的是 start 方法会被正常调用，但在该方法结束并且我设置了回调方法的连接后，它永远不会调用。之后队列中不再执行任何操作。就好像它在 start 方法返回后挂起，并且没有调用任何 url 连接的回调！

如果我的并发操作首先放入队列中，那么一切都会正常工作，异步回调会工作，后续操作会在完成后执行。我根本不明白！

您可以在下面看到我的并发 NSOperation 的测试代码，我非常确定它是可靠的。

任何帮助将不胜感激！

主线程观察：

我刚刚发现，如果并发操作首先在队列上，则在主线程上调用 [start] 方法。但是，如果它不是队列中的第一个（如果它位于并发或非并发之后），则不会在主线程上调用 [start] 方法。这似乎很重要，因为它符合我的问题模式。这可能是什么原因？

并发 NSOperation 代码：

@interface ConcurrentOperation : NSOperation {
    BOOL executing;
    BOOL finished;
}
- (void)beginOperation;
- (void)completeOperation;
@end

@implementation ConcurrentOperation
- (void)beginOperation {
    @try {

        // Test async request
        NSURLRequest *r = [[NSURLRequest alloc] initWithURL:[NSURL URLWithString:@"http://www.google.com"]];
        NSURLConnection *c = [[NSURLConnection alloc] initWithRequest:r delegate:self];
        [r release];

    } @catch(NSException * e) {
        // Do not rethrow exceptions.
    }
}
- (void)connectionDidFinishLoading:(NSURLConnection *)connection {
    NSLog(@"Finished loading... %@", connection);
    [self completeOperation];
}
- (void)connection:(NSURLConnection *)connection didFailWithError:(NSError *)error {
    NSLog(@"Finished with error... %@", error);
    [self completeOperation]; 
}
- (void)dealloc {
    [super dealloc];
}
- (id)init {
    if (self = [super init]) {

        // Set Flags
        executing = NO;
        finished = NO;

    }
    return self;
}
- (void)start {

    // Main thread? This seems to be an important point
    NSLog(@"%@ on main thread", ([NSThread isMainThread] ? @"Is" : @"Not"));

    // Check for cancellation
    if ([self isCancelled]) {
        [self completeOperation];
        return;
    }

    // Executing
    [self willChangeValueForKey:@"isExecuting"];
    executing = YES;
    [self didChangeValueForKey:@"isExecuting"];

    // Begin
    [self beginOperation];

}

// Complete Operation and Mark as Finished
- (void)completeOperation {
    BOOL oldExecuting = executing;
    BOOL oldFinished = finished;
    if (oldExecuting) [self willChangeValueForKey:@"isExecuting"];
    if (!oldFinished) [self willChangeValueForKey:@"isFinished"];
    executing = NO;
    finished = YES;
    if (oldExecuting) [self didChangeValueForKey:@"isExecuting"];
    if (!oldFinished) [self didChangeValueForKey:@"isFinished"];
}

// Operation State
- (BOOL)isConcurrent { return YES; }
- (BOOL)isExecuting { return executing; }
- (BOOL)isFinished { return finished; }

@end

排队代码

// Setup Queue
myQueue = [[NSOperationQueue alloc] init];
[myQueue setMaxConcurrentOperationCount:1];

// Non Concurrent Op
NonConcurrentOperation *op1 = [[NonConcurrentOperation alloc] init];
[myQueue addOperation:op1];
[op1 release];

// Concurrent Op
ConcurrentOperation *op2 = [[ConcurrentOperation alloc] init];
[myQueue addOperation:op2];
[op2 release];

Answer 1

我已经发现问题所在了！

Dave Dribin 的这两篇无价文章详细描述了并发操作，以及 Snow Leopard 和 Java 中存在的问题。 iPhone SDK 在异步调用需要运行循环的事物时引入了这一点。

http://www.dribin.org/dave/blog/档案/2009/05/05/concurrent_operations/
http://www.dribin.org/dave/blog/ archives/2009/09/13/snowy_concurrent_operations/

也感谢 Chris Suter 为我指明了正确的方向！

关键是要确保我们在主线程上调用 start 方法：

- (void)start {

    if (![NSThread isMainThread]) { // Dave Dribin is a legend!
        [self performSelectorOnMainThread:@selector(start) withObject:nil waitUntilDone:NO];
        return;
    }

    [self willChangeValueForKey:@"isExecuting"];
    _isExecuting = YES;
    [self didChangeValueForKey:@"isExecuting"];

    // Start asynchronous API

}

Answer 2

您的问题很可能与 NSURLConnection 有关。 NSURLConnection 依赖于运行某种模式的运行循环（通常只是默认模式）。

您的问题有多种解决方案：

1. 确保此操作仅在主线程上运行。如果您在 OS X 上执行此操作，您需要检查它是否在所有运行循环模式（例如模态和事件跟踪模式）中执行您想要的操作，但我不知道 iPhone 上的情况如何。< /p>

2. 创建并管理您自己的线程。这不是一个好的解决方案。

3. 调用 -[NSURLConnection ScheduleInRunLoop:forMode:] 并传入主线程或您了解的另一个线程。如果这样做，您可能需要首先调用 -[NSURLConnection unscheduleInRunLoop:forMode:] ，否则您可能会在多个线程中接收数据（或者至少文档似乎是这么建议的）。

4. 使用类似 +[NSData dataWithContentsOfURL:options:error:] 的内容，这也会简化您的操作，因为您可以将其设为非并发操作。

   使用类似

5. #4 的变体：使用 +[NSURLConnection sendSynchronousRequest:returningResponse:error:]。

如果你能逃脱惩罚，请执行#4 或#5。

Answer 3

我没有注意到，也没有看到任何提及 addDependency: 的内容，这似乎是让操作按正确顺序执行的先决条件。

简而言之，第二个操作取决于第一个操作。