如何包装异步类以使其同步？使用 NSRunLoop？

Question

我目前正在开发一个 iPhone 应用程序，我有一个来自第三方的库，它具有异步行为，但我想用我自己的类包装它并使其看起来同步。

该库中的中心类（我们称之为 Connection 类）具有多个函数，当调用委托类实例上的方法时，这些函数将解析其最终结果。我想做的是包装此类和委托，使其看起来是同步的而不是异步的。如果我在 Java 中执行此操作，我会使用 FutureTask 或 CountdownLatch 或只是 join()。但我不确定在 Objective C 中执行此操作的最佳方法。

我首先创建一个 NSThread 扩展 NFCThread，它符合上述委托协议。我的想法是，我将初始化 NFCThread，将 NFCThread 实例传递给 Connection 的 setDelegate 方法，启动线程，然后调用 Connection 上的异步方法。我的期望是，最终将调用 NFCThread 实例上的三个委托方法之一，导致线程退出。

为了模拟连接，我执行了以下操作。我向 NFCThread 添加了 NSConditionalLock：

joinLock = [[NSConditionLock alloc] initWithCondition:NO];

调用 Connection 的代码看起来像这样：

NFCThread *t = [[NFCThread alloc] init];
[connection setDelegate:t];
[t start];

[connection openSession];
// Process errors, etc...

[t.joinLock lockWhenCondition:YES];
[t.joinLock unlock];
[t release];
[connection setDelegate:nil];

委托的协议具有三个方法。在 NFCThread 中，我实现了每个方法，如下所示：

- (void)didReceiveMessage:(CommandType)cmdType 
                     data:(NSString *)responseData 
               length:(NSInteger)length {
    NSLog(@"didReceiveMessage");
    // Do something with data and cmdType...
    [joinLock lock];
    [joinLock unlockWithCondition:YES];
    callBackInvoked = YES;
}

我重载了 NFCThread 的 main 方法，以便它不断循环。像这样的事情：

while (!callBackInvoked) { ; }

我发现这并不是一个好主意，因为它会导致 cpu 使用率飙升。因此，我尝试使用我在本网站上找到的一些示例中的运行循环：

NSRunLoop *runLoop = [NSRunLoop currentRunLoop];
[runLoop addPort:[NSMachPort port] forMode:NSDefaultRunLoopMode];

while (!callBackInvoked) {
    [runLoop runMode:NSDefaultRunLoopMode beforeDate:[NSDate distantFuture]];
}

在我的两个实现中，主线程始终被阻塞，并且似乎没有调用任何委托方法。但是，我知道该库运行正常，并且通常会调用对委托方法的调用。

我觉得我在这里遗漏了一些明显的东西。非常感谢任何帮助。

富有的

Answer 1

我刚刚实现了类似的东西。背景是：
- 在后台线程中包装对 ZipArchive 的多次调用
- 每次调用解压缩时，显示不同的进度表（无限旋转的轮子，并显示正在扩展的文件名）
- 当所有档案都已展开时执行清理任务

结果 NSConditionLock 使其变得简单，代码的工作原理如下：

NSConditionLock* lock = alloc/init
for(int idx = 0; idx < [list count]; idx++) {
  NSString* fileName = ["getIdx's element in list"]
  [cond lockWhenCondition:idx]; //

  ... prepare things before forking

  [cond unlockWithCondition:-1];
  [Notification forkBlock:^(void){
    [cond lockWhenCondition:-1];

    NSAutoreleasePool *pool = [alloc/init];
    [ZipArchive unzipFile:fileName];
    [pool release];
    [cond unlockWithCondition:idx+1];
  }];
}

[cond lockWhenCondition:[list count];
// all the tasks are now completed

每个块都在后台线程中调度。 Notification 类负责使用旋转轮对 UIView 进行动画处理，并将该块包装在另一个线程中。锁定/解锁必须从同一线程调用，因此条件是启用后台线程和后台线程之间的乒乓（-1 表示后台，1,2,3..n 表示前台）。

Answer 2

好吧，这里有一些不同的问题，我正在考虑从哪里开始。

但是，为了让我们理解您想要完成的任务，当您说您希望调用“看起来”同步时，您的意思是您希望调用被阻止吗？您是从主线程进行此调用吗？如果是这样，那么您似乎有意阻止主线程。

请记住，第三方库可能正在主运行循环上安排事件。您可以创建自己的运行循环并在另一个线程中运行它，但是您是否告诉其他库将该运行循环用于其事件？ （例如，它可能会发出安排在您已阻止的主运行循环上的异步网络请求）

我会重新考虑一下您在做什么，但首先我们需要知道您的意图是否是阻止线程您正在拨打此电话。另外，需要支持iPhoneOS 3.x吗？

Answer 3

您想要做的是使用 NSCondition 等待当前线程，并在第二个线程上发出信号以让第一个线程继续。

- (void) firstThread
{
    workIsDone = NO;
    //Start second thread here
    [condition lock];
    while (!workIsDone) {
        [condition wait];
    }
    [condition unlock];

    // Keep going
}

- (void) secondThread
{
    [condition lock];

    //Do some work.
    workIsDone = YES;
    [condition signal];
    [condition unlock];
}

Answer 4

您需要一个信号量，它将允许您的主代码路径阻塞，直到您的异步回调向信号量发出信号并允许其继续。

iOS 4 中可以通过 Grand Central Dispatch 使用信号量。

看来信号量的行为可以在 iOS 3 中通过 NSCondition 来实现。