如何在 NSOperation 中执行异步 NSURLConnection?

发布于 2024-08-02 13:34:10 字数 4027 浏览 1 评论 0原文

我想在后台线程上的 NSOperation 内部执行异步 NSURLConnection 。

(这是因为我正在对数据进行一些非常昂贵的操作,因为它们返回时希望在数据进入和在后台时完成)

这是我的第一次尝试:

在我的AppDelegate中:

// create the opperation and add it to the queue:
self.sharedOperationQueue = [[[NSOperationQueue alloc] init] autorelease];
LibXMLOperation *op = [[[LibXMLOperation alloc] init] autorelease];
[self.sharedOperationQueue addOperation:op];

这是我的操作:

@interface EbirdLibXMLOperation : NSOperation {
@private
  NSURLConnection *urlConnection;
 // Overall state of the parser, used to exit the run loop.
 BOOL done;
 // properties to maintain the NSOperation
 BOOL finished;
 BOOL executing;  
}
- (void)downloadAndParse:(NSURL *)url;
- (void)start;
- (BOOL)isConcurrent;
- (BOOL)isFinished;
- (BOOL)isExecuting;

@property BOOL done;
@property (nonatomic, retain) NSURLConnection *ebirdConnection;
// The autorelease pool property is assign because autorelease pools cannot be retained.
@property (nonatomic, assign) NSAutoreleasePool *downloadAndParsePool;

@end


@implementation LibXMLOperation
@synthesize urlConnection, done;

- (void)start{
  if (![self isCancelled]) {
    [self willChangeValueForKey:@"isExecuting"];
    executing = YES;
    //set up the thread and kick it off...
    [[NSURLCache sharedURLCache] removeAllCachedResponses];
    NSURL *url = [NSURL URLWithString:@"http://google.com"];
    [NSThread detachNewThreadSelector:@selector(downloadAndParse:) toTarget:self withObject:url];
    [self didChangeValueForKey:@"isExecuting"];
  } else {
    // If it's already been cancelled, mark the operation as finished.
    [self willChangeValueForKey:@"isFinished"];
    finished = YES;
    [self didChangeValueForKey:@"isFinished"];
  }
}

- (BOOL)isConcurrent {
  return YES;
}

- (BOOL)isExecuting {
  return executing;
}

- (BOOL)isFinished {
  return finished;
}


- (void)downloadAndParse:(NSURL *)url {
  self.downloadAndParsePool = [[NSAutoreleasePool alloc] init];
  done = NO;
  self.characterBuffer = [NSMutableData data];
  [[NSURLCache sharedURLCache] removeAllCachedResponses];
  NSURLRequest *theRequest = [NSURLRequest requestWithURL:url];
  urlConnection = [[NSURLConnection alloc] initWithRequest:theRequest delegate:self];
  if (urlConnection != nil) {
    do {
      [[NSRunLoop currentRunLoop] runMode:NSDefaultRunLoopMode beforeDate:[NSDate distantFuture]];
    } while (!done);
  }
  [self willChangeValueForKey:@"isFinished"];
  [self willChangeValueForKey:@"isExecuting"];
  finished = YES;
  executing = NO;
  // Clean up.
  self.urlConnection = nil;
  [downloadAndParsePool release];
  NSLog(@"download and parse cleaning up");
  self.downloadAndParsePool = nil;
  [self didChangeValueForKey:@"isExecuting"];
  [self didChangeValueForKey:@"isFinished"];  
}


#pragma mark NSURLConnection Delegate methods

// Disable caching so that each time we run this app we are starting with a clean slate.

- (NSCachedURLResponse *)connection:(NSURLConnection *)connection willCacheResponse:(NSCachedURLResponse *)cachedResponse {
  return nil;
}

// Forward errors to the delegate.
- (void)connection:(NSURLConnection *)connection didFailWithError:(NSError *)error {
  done = YES;
}

// Called when a chunk of data has been downloaded.
- (void)connection:(NSURLConnection *)connection didReceiveData:(NSData *)data {
  // Process the downloaded chunk of data.
  NSLog(@"Did received %i bytes", [data length]);
}

- (void)connectionDidFinishLoading:(NSURLConnection *)connection {
  // Set the condition which ends the run loop.
  done = YES; 
}    

@end

当这个运行时,我在日志中看到以下消息:

2009-08-20 15:18:48.858 App[1001:3e03]*** _NSAutoreleaseNoPool(): Object 0x1126a20 of class NSCFArray autoreleased with no pool in place - just leaking
Stack: (0x305a2e6f 0x30504682 0x3057deba 0x305ced09 0x30577ddf 0x3056b43e 0x3050764a 0x58fc3 0x3050a79d 0x3050a338 0x94568155 0x94568012)

此事件发生在最后 [self didChangeValueForKey:@"isFinished"];这表明我设置的 NSOperation 是错误的。

I want to do an Asynchrous NSURLConnection inside of an NSOperation on a background thread.

(it is because I'm doing some very expensive operations on the data as they come back that want to be done as the data comes in and in background)

Here is my first attempt:

IN my AppDelegate:

// create the opperation and add it to the queue:
self.sharedOperationQueue = [[[NSOperationQueue alloc] init] autorelease];
LibXMLOperation *op = [[[LibXMLOperation alloc] init] autorelease];
[self.sharedOperationQueue addOperation:op];

Here is my operation:

@interface EbirdLibXMLOperation : NSOperation {
@private
  NSURLConnection *urlConnection;
 // Overall state of the parser, used to exit the run loop.
 BOOL done;
 // properties to maintain the NSOperation
 BOOL finished;
 BOOL executing;  
}
- (void)downloadAndParse:(NSURL *)url;
- (void)start;
- (BOOL)isConcurrent;
- (BOOL)isFinished;
- (BOOL)isExecuting;

@property BOOL done;
@property (nonatomic, retain) NSURLConnection *ebirdConnection;
// The autorelease pool property is assign because autorelease pools cannot be retained.
@property (nonatomic, assign) NSAutoreleasePool *downloadAndParsePool;

@end


@implementation LibXMLOperation
@synthesize urlConnection, done;

- (void)start{
  if (![self isCancelled]) {
    [self willChangeValueForKey:@"isExecuting"];
    executing = YES;
    //set up the thread and kick it off...
    [[NSURLCache sharedURLCache] removeAllCachedResponses];
    NSURL *url = [NSURL URLWithString:@"http://google.com"];
    [NSThread detachNewThreadSelector:@selector(downloadAndParse:) toTarget:self withObject:url];
    [self didChangeValueForKey:@"isExecuting"];
  } else {
    // If it's already been cancelled, mark the operation as finished.
    [self willChangeValueForKey:@"isFinished"];
    finished = YES;
    [self didChangeValueForKey:@"isFinished"];
  }
}

- (BOOL)isConcurrent {
  return YES;
}

- (BOOL)isExecuting {
  return executing;
}

- (BOOL)isFinished {
  return finished;
}


- (void)downloadAndParse:(NSURL *)url {
  self.downloadAndParsePool = [[NSAutoreleasePool alloc] init];
  done = NO;
  self.characterBuffer = [NSMutableData data];
  [[NSURLCache sharedURLCache] removeAllCachedResponses];
  NSURLRequest *theRequest = [NSURLRequest requestWithURL:url];
  urlConnection = [[NSURLConnection alloc] initWithRequest:theRequest delegate:self];
  if (urlConnection != nil) {
    do {
      [[NSRunLoop currentRunLoop] runMode:NSDefaultRunLoopMode beforeDate:[NSDate distantFuture]];
    } while (!done);
  }
  [self willChangeValueForKey:@"isFinished"];
  [self willChangeValueForKey:@"isExecuting"];
  finished = YES;
  executing = NO;
  // Clean up.
  self.urlConnection = nil;
  [downloadAndParsePool release];
  NSLog(@"download and parse cleaning up");
  self.downloadAndParsePool = nil;
  [self didChangeValueForKey:@"isExecuting"];
  [self didChangeValueForKey:@"isFinished"];  
}


#pragma mark NSURLConnection Delegate methods

// Disable caching so that each time we run this app we are starting with a clean slate.

- (NSCachedURLResponse *)connection:(NSURLConnection *)connection willCacheResponse:(NSCachedURLResponse *)cachedResponse {
  return nil;
}

// Forward errors to the delegate.
- (void)connection:(NSURLConnection *)connection didFailWithError:(NSError *)error {
  done = YES;
}

// Called when a chunk of data has been downloaded.
- (void)connection:(NSURLConnection *)connection didReceiveData:(NSData *)data {
  // Process the downloaded chunk of data.
  NSLog(@"Did received %i bytes", [data length]);
}

- (void)connectionDidFinishLoading:(NSURLConnection *)connection {
  // Set the condition which ends the run loop.
  done = YES; 
}    

@end

When this runs, I see the following message in my log:

2009-08-20 15:18:48.858 App[1001:3e03]*** _NSAutoreleaseNoPool(): Object 0x1126a20 of class NSCFArray autoreleased with no pool in place - just leaking
Stack: (0x305a2e6f 0x30504682 0x3057deba 0x305ced09 0x30577ddf 0x3056b43e 0x3050764a 0x58fc3 0x3050a79d 0x3050a338 0x94568155 0x94568012)

This event happens at the very last [self didChangeValueForKey:@"isFinished"]; which suggests to me that I'm setting up the NSOperation wrong.

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(1

情泪▽动烟 2024-08-09 13:34:10

将以下行移动

[downloadAndParsePool release];
self.downloadAndParsePool = nil;

-downloadAndParse: 方法的末尾。

Move the lines:

[downloadAndParsePool release];
self.downloadAndParsePool = nil;

to the end of the -downloadAndParse: method.

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文