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