RACrac函数响应式编程

RAC(ReactiveCocoa)介绍(十)——RACMult

2018-06-02  本文已影响601人  我只不过是出来写写代码

在实际项目开发过程中,经常会在多处不同地方对同一信号进行订阅。比如:在网络请求时,收到返回数据要针对页面多处进行更新操作。
通常会出现以下RAC写法:

一个信号多个订阅者的错误示范
这样的错误写法打印结果如下:
错误示范的打印结果
从打印结果来看,很明显地RACSignal拥有两个订阅者时,发送信号与销毁信号都执行了两次。当拥有更多订阅者或者需要在发送信号前耗时处理时,这种写法大大降低了运行效率,浪费了不必要的资源。
针对这种情况,就需要使用RACMulticastConnection来处理。
将上述问题代码加入进RACMulticastConnection处理之后
引入RACMulticastConnection之后
这时再查看打印结果
引入RACMulticastConnection打印结果
发送信号时只执行了一次,两个订阅者都收到了各自的订阅信号。

为什么RACMulticastConnection可以实现一次发送多处订阅者就可以收到信号?
带着问题去查看其内部实现过程

publish方法实现
从上图代码实现中,可以发现RACMulticastConnection是基于RACSubject来实现的,并将RACSubject封装成了RACMulticastConnection对象。打印connection.signal,可以发现是为RACSubject类的对象。
再继续进入至- (instancetype)initWithSourceSignal:(RACSignal *)source subject:(RACSubject *)subject方法中。
RACMulticastConnection内部实现方法
此处使用了方法bool OSAtomicCompareAndSwap32Barrier( int32_t __oldValue, int32_t __newValue, volatile int32_t *__theValue );
用于将_hasConnected0(oldValue)进行比较,如果两者是匹配的,则方法结果返回YES并将_hasConnected赋值为1(newValue)。即由未连接状态,修改成已连接状态。
当由未连接状态变为已连接状态时,执行信号的订阅方法。

总结一下RACMulticastConnection实现过程:
1.创建connectconnect.sourceSignal-> RACSignal(原始信号) connect.signal -> RACSubject
2.订阅connect.signal,会调用RACSubjectsubscribeNext,创建订阅者,而且把订阅者保存起来,不会执行block。
3.[connect connect]内部会订阅RACSignal(原始信号),并且订阅者是RACSubject
4.RACSubjectsendNext,会遍历RACSubject所有订阅者发送信号,并执行他们的nextBlock( )

上一篇 下一篇

猜你喜欢

热点阅读