美文网首页RACrac函数响应式编程
RAC(ReactiveCocoa)介绍(十)——RACMult

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

作者: 我只不过是出来写写代码 | 来源:发表于2018-06-02 01:04 被阅读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( )

    相关文章

      网友评论

        本文标题:RAC(ReactiveCocoa)介绍(十)——RACMult

        本文链接:https://www.haomeiwen.com/subject/mrjlsftx.html