iOS 多线程(六)-线程间通信

iOS 中，两个线程之间要想互相通信，可以使用：NSMachPort
示例：

#import "ViewController.h"
#import "MyWorkerClass.h"
@interface ViewController ()<NSMachPortDelegate>

@end

@implementation ViewController

- (void)viewDidLoad {
    [super viewDidLoad];
    self.view.backgroundColor = [UIColor orangeColor];
    //1. 创建主线程的port
    // 子线程通过此端口发送消息给主线程
    NSPort *myPort = [NSMachPort port];
 
    //2. 设置port的代理回调对象
    myPort.delegate = self;
 
    //3. 把port加入runloop，接收port消息
    [[NSRunLoop currentRunLoop] addPort:myPort forMode:NSDefaultRunLoopMode];
 
    NSLog(@"---myport %@", myPort);
    //4. 启动次线程,并传入主线程的port
    MyWorkerClass *work = [[MyWorkerClass alloc] init];
    [NSThread detachNewThreadSelector:@selector(launchThreadWithPort:)
                             toTarget:work
                           withObject:myPort];
}

#pragma mark - NSPortDelegate
- (void)handlePortMessage:(NSMessagePort*)message{
 
    NSLog(@"接到子线程传递的消息！%@",message);
    //1. 消息id
    NSUInteger msgId = [[message valueForKeyPath:@"msgid"] integerValue];
    //2. 当前主线程的port
    NSPort *localPort = [message valueForKeyPath:@"localPort"];
    //3. 接收到消息的port（来自其他线程）
    NSPort *remotePort = [message valueForKeyPath:@"remotePort"];
 
    if (msgId == 100)
    {
        //向子线的port发送消息
        [remotePort sendBeforeDate:[NSDate date]
                             msgid:200
                        components:nil
                              from:localPort
                          reserved:0];
 
    }
}


@end

#import <Foundation/Foundation.h>

@interface MyWorkerClass : NSObject

@end


#import "MyWorkerClass.h"

@interface MyWorkerClass ()<NSMachPortDelegate> {
    NSPort *remotePort;
    NSPort *myPort;
}

@end
@implementation MyWorkerClass

- (void)launchThreadWithPort:(NSPort *)port {

   @autoreleasepool {

       //1. 保存主线程传入的port
       remotePort = port;

       //2. 设置子线程名字
       [[NSThread currentThread] setName:@"MyWorkerClassThread"];

       //3. 开启runloop
       [[NSRunLoop currentRunLoop] run];

       //4. 创建自己port
       myPort = [NSPort port];

       //5.
       myPort.delegate = self;

       //6. 将自己的port添加到runloop
       //作用1、防止runloop执行完毕之后推出
       //作用2、接收主线程发送过来的port消息
       [[NSRunLoop currentRunLoop] addPort:myPort forMode:NSDefaultRunLoopMode];

       //7. 完成向主线程port发送消息
       [self sendPortMessage];

   }
}

/**
*   完成向主线程发送port消息
*/
- (void)sendPortMessage {

   NSMutableArray *array  =[[NSMutableArray alloc]initWithArray:@[@"1",@"2"]];
   //发送消息到主线程
   [remotePort sendBeforeDate:[NSDate date]
                        msgid:100
                   components:array
                         from:myPort
                     reserved:0];

}


#pragma mark - NSPortDelegate

/**
*  接收到主线程port消息
*/
- (void)handlePortMessage:(NSPortMessage *)message
{
   NSLog(@"接收到父线程的消息...\n");

   //    unsigned int msgid = [message msgid];
   //    NSPort* distantPort = nil;
   //
   //    if (msgid == kCheckinMessage)
   //    {
   //        distantPort = [message sendPort];
   //
   //    }
   //    else if(msgid == kExitMessage)
   //    {
   //        CFRunLoopStop((__bridge CFRunLoopRef)[NSRunLoop currentRunLoop]);
   //    }
}

@end