cocoa 线程操作

在Cocoa 中创建线程使用NSThread类的detachNewThreadSelector: toTarget:withObject:方法

NSPort *port1 = [NSPort port];
NSPort *port2 = [NSPort port];
NSArray *userInfo= nil;
NSConnection* kitConnection = nil;
kitConnection = [[NSConnection alloc] initWithReceivePort:port1 sendPort:port2];
[kitConnection setRootObject:self];

userInfo= [NSArray arrayWithObjects:port2, port1, nil];
[NSThread detachNewThreadSelector:@selector(newThread:)
            toTarget:target withObject:userInfo];

newThread:就是我们要创建的线程。它需要一个参数，返回值为空。

-(void)newThread:(id)userInfo

target:用来在创建的线程中接收newThread的消息。

userInfo:主线程传给新建线程的参数。

另外，注意主线程和子线程中的connection的port顺序。

在-(void)newThread:(id)userInfo中需要了解的是：

1）首先，需要创建一个自动释放池。

2）在新建的线程的执行过程中，target和userInfo是retain的，线程结束后会自动的release掉。

3）target一旦完成了newThread，线程即刻结束。

4）为了使线程处于活跃状态，以便在稍后进行通信，需要在newThread中加入：

      [[NSRunLoop  currentRunLoop] run];或者runMode:beforeDate，runUntilDate等。

一般情况下，应用程序不需要创建和管理NSRunLoop类。每个NSThread，包括应用程序主线程都有一个自动为其创建的NSRunLoop对象，然而只有使用Application Kit的应用程序主线程会自动运行它的运行循环(run loop)，除此之外的线程(或 Foundation Kit tools)必须显式的运行它们自己的运行循环(run loop)。

下面是示例代码：

- (void)newThread:(id)userInfo
{
    NSAutoreleasePool *pool;
    NSConnection *serverConnection;
    mySubThread *subThreadWorker;

    pool = [[NSAutoreleasePool alloc] init];

    serverConnection= [NSConnection
            connectionWithReceivePort:[userInfo objectAtIndex:0]
            sendPort:[userInfo objectAtIndex:1]];

    subThreadWorker = [[mySubThread alloc] init];

    [serverConnection setRootObject: self];

    //do something;

     do
    {
       [[NSRunLoop currentRunLoop] runMode:NSDefaultRunLoopMode
               beforeDate:[NSDate distantFuture]];
    } while (![subThreadWorker shouldExit]);

   [subThreadWorker release];
   [pool release];

    return;
}

在 serverConnection= [NSConnection connectionWithReceivePort:[userInfo objectAtIndex:0] sendPort:[userInfo objectAtIndex:1]];完成之后，

要建立主线程和子线程之间的通信，还需要在//do something之前加上这样一句代码：

[(id)[serverConnection rootProxy] setServer: subThreadWorker];

setServer：是主线程中的方法。

执行这个方法，是为子线程在主线程中设置一个代理。

这样，在主线程中，就可以通过这个代理，来响应和执行子线程中的一些消息了。

下面给出一个主线程中的setServer：的示例：

- (void)setServer:(id)anObject
{
    [anObject setProtocolForProxy:@protocol(WorkerMethods)];
    work = (id <WorkerMethods>)[anObject retain];
    return;
}

其中，work就相当于子线程在主线程的代理。

在主线程中，只要使work作为子线程消息的接收者，就可以响应和执行子线程的消息啦。

至此，主线程和子线程之间的连接就建立起来了。

此外，需要注意的一点是：在setServer：中我们看到，传入的参数anObject是被retain了的。

因此，在子线程newThread：中，在调用了setServer：之后，可以将参数release掉。

这样，主线程唯一保有work的引用，不会造成内存泄露。

[(id)[serverConnection rootProxy] setServer: workerObject];
[workerObject release];