objective-c - 如何管理在辅助线程中运行的 NSRunLoop 的自动释放池？

Question

在苹果的 MVCNetworking示例代码，NetworkManager 类包含此方法以在专用于网络事件的辅助线程中维护运行循环(以便异步运行 NSURLConnection):

- (void)networkRunLoopThreadEntry
{
    while(YES) {
        NSAutoreleasePool *pool;
        pool = [[NSAutorelease alloc] init];
        [[NSRunLoop currentRunLoop] run];
        [pool drain];
    }
}

由于 run 方法会在没有源附加到 run loop 时立即退出，这看起来像一个无限的 while 循环，它会无用地消耗 CPU 资源，如果当前没有 NSURLConnection 附加到运行循环。

另一方面，为了保持运行循环活跃，some suggests在运行循环中安排一个空端口:

 - (void)networkRunLoopThreadEntry
 {
     NSAutoreleasePool *pool = [[NSAutorelease alloc] init];
     NSPort *port = [NSPort port];
     [[NSRunLoop currentRunLoop] addPort:port forMode:NSRunLoopCommonModes];
     [NSRunLoop run];
     [pool drain];
 }

但是，在这种情况下，我担心的是 run 方法永远不会退出，这意味着池永远不会被耗尽，这意味着在辅助线程中分配和自动释放的所有对象都会泄漏。

那该怎么走呢？

(对于上下文，与其他许多人一样，我试图将异步 NSURLConnection 封装在 NSOperation 中，这意味着它可以在主线程之外触发. 此外，MVCNetworking 示例代码以及 WWDC 2010 session iPhone OS 网络应用 似乎表明，拥有一个专用于网络传输的独特辅助线程以防止网络延迟是个好主意主线程。)

Answer 1

您可以创建一个 CFRunLoopObserver对于 kCFRunLoopBeforeWaiting 事件并将其添加到运行循环中。在观察者的标注中，释放旧池并创建一个新池。未经测试的例子:

static void resetPoolCallout(CFRunLoopObserverRef observer, CFRunLoopActivity activity, void *info) {
    NSAutoreleasePool **poolPointer = (NSAutoreleasePool **)info;
    [*poolPointer release];
    *poolPointer = [[NSAutoreleasePool alloc] init];
}

- (void)networkRunLoopThreadEntry {
    NSAutoreleasePool *pool = [[NSAutoreleasePool alloc] init];
    NSPort *port = [NSPort port];
    [[NSRunLoop currentRunLoop] addPort:port forMode:NSRunLoopCommonModes];

    CFRunLoopObserverContext observerContext = {
        .version = 0,
        .info = (void*)&pool,
        .retain = NULL,
        .release = NULL,
        .copyDescription = NULL
    };
    CFRunLoopObserverRef observer = CFRunLoopObserverCreate(NULL, kCFRunLoopBeforeWaiting,
        true, 0, resetPoolCallout, &observerContext);
    CFRunLoopAddObserver(CFRunLoopGetCurrent(), observer, kCFRunLoopCommonModes);

    [[NSRunLoop currentRunLoop] run];

    CFRunLoopRemoveObserver(CFRunLoopGetCurrent(), observer, kCFRunLoopCommonModes);
    CFRelease(observer);

    [pool release];
}