通知同步异步的验证，通知的重定向
验证 NSNotification 的同步和异步问题
我们先来这样发送一个通知
-(void)touchesBegan:(NSSet<UITouch *> *)touches withEvent:(UIEvent *)event{
SCXNotiTest *noti = [SCXNotiTest new];
self.noti = noti;
dispatch_async(dispatch_get_global_queue(0, 0), ^{
[[NSNotificationCenter defaultCenter] postNotificationName:@"noti" object:nil];
NSLog(@"完成了");
// 根据log打印可以看出是同步的，等通知中心把通知发送给所有的接受者并处理完成之后，才会返回poster继续向下执行
});
}
从代码里面可以看到 我们在子线程里面发送了一个通知，在发送通知之后打印完成了，而我们在接受通知的时候，做了什么呢?
- (void)noti:(NSNotification *)noti{
NSLog(@"%@",[NSThread currentThread]);
sleep(3);
NSLog(@"处理通知完成了");
}
看一下log
2018-06-01 17:44:56.840719+0800 NotificationDemo[22960:1203838] <NSThread: 0x600000261200>{number = 3, name = (null)}
2018-06-01 17:44:59.845206+0800 NotificationDemo[22960:1203838] 处理通知完成了
2018-06-01 17:44:59.845370+0800 NotificationDemo[22960:1203838] 完成了
从 log 上面可以看出，我们在子线程里面发送通知之后，没有立刻打印“完成了”，而是会等5S，接受通知任务完成之后，参会打印“完成了”，可见NSNotification是阻塞当前线程的，会等通知发送给所有的接受对象之后，并且，所有的接受对象指向完任务之后，才会才会poster继续向下执行任务，由此证明了，NSNotification是同步的
多线程接受通知
我们上面是在一个子线程中发送的通知，如果我们想切换线程，切换到主线程去接受通知，可以吗？
dispatch_async(dispatch_get_main_queue(), ^{
[[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(noti:) name:@"noti" object:nil];
});
控制台 log
2018-06-01 17:48:53.192514+0800 NotificationDemo[23171:1217043] 完成了
通知没有执行，可见是不行的。
怎样解决多线程接受的问题
官方曾经给过DEMO，大概意思就是重定向,我们在一个线程中发送通知，然后将它重定向到其他的线程，大体思路就是自定义一个通知的队列，让这个队列去维护我们的 NSNotification ，那么怎样才能在主线程中执行了，有一种方式
- (void)noti:(NSNotification *)noti{
dispatch_async(dispatch_get_main_queue(), ^{
NSLog(@"%@",[NSThread currentThread]);
sleep(3);
NSLog(@"处理通知完成了");
});
}
这是我们通常的做法，那么如果不这样，切换到我们的某个自定义的 NSThread 中呢
直接上代码吧
#import "SCXNotiTest.h"
@interface SCXNotiTest()<NSMachPortDelegate>
/**
通知队列
*/
@property(nonatomic , strong)NSMutableArray *notisQueues;
/**
通知需要执行的队列
*/
@property(nonatomic , strong)NSThread *targetThread;
/**
线程锁
*/
@property(nonatomic , strong)NSLock *lock;
/**
用于激活期望线程的信号
*/
@property(nonatomic , strong)NSMachPort *port;
@end
@implementation SCXNotiTest
-(instancetype)init{
if (self = [super init]) {
dispatch_async(dispatch_get_global_queue(0, 0), ^{
self.notisQueues = [NSMutableArray array];
self.targetThread = [NSThread currentThread];
self.lock = [[NSLock alloc] init];
self.port = [[NSMachPort alloc] init];
self.port.delegate = self;
[[NSRunLoop currentRunLoop ] addPort:self.port forMode:NSRunLoopCommonModes];
[[NSRunLoop currentRunLoop] run];
});
[[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(redirectNoti:) name:@"noti" object:nil];
}
return self;
}
- (void)redirectNoti:(NSNotification *)noti{
if ([NSThread currentThread] != self.targetThread) {
[self.lock lock];
[self.notisQueues addObject:noti];
[self.lock unlock];
[self.port sendBeforeDate:[NSDate date] components:nil from:nil reserved:0];
}
}
- (void)noti:(NSNotification *)noti{
NSLog(@"%@",[NSThread currentThread]);
sleep(3);
NSLog(@"处理通知完成了");
}
-(void)handleMachMessage:(void *)msg{
[self.lock lock];
while (self.notisQueues.count) {
NSNotification *noti = self.notisQueues[0];
[self.notisQueues removeObjectAtIndex:0];
[self.lock unlock];
[self noti:noti];
[self.lock lock];
}
[self.lock unlock];
}
-(void)dealloc{
NSLog(@"dealloc");
}
@end
原理是，当我们收到一个通知的时候，先判断是不是我们创建的线程，如果不是，添加到我们的队列当中去，然后通过端口的方式触发到制定线程去，然后遍历我们的队列，先进先出的方式去处理对应的任务就OK了，上面试在主线程中处理，那么怎样在子线程中处理呢？我们都知道，子线程是需要手动开启 runloop的，改造一下上面的代码
dispatch_async(dispatch_get_global_queue(0, 0), ^{
self.notisQueues = [NSMutableArray array];
self.targetThread = [NSThread currentThread];
self.lock = [[NSLock alloc] init];
self.port = [[NSMachPort alloc] init];
self.port.delegate = self;
[[NSRunLoop currentRunLoop ] addPort:self.port forMode:NSRunLoopCommonModes];
[[NSRunLoop currentRunLoop] run];
});
