美文网首页函数响应式编程raciOS-RAC
RAC(ReactiveCocoa)介绍(六)——RACSche

RAC(ReactiveCocoa)介绍(六)——RACSche

作者: 我只不过是出来写写代码 | 来源:发表于2018-05-27 23:15 被阅读97次

    上一篇介绍了一下RAC订阅信号中,方法实现RACCompoundDisposable真正的订阅者类的相关介绍。
    这一篇,将在订阅信号的方法中继续探究,当真正的订阅者初始化之后,后续代码涉及到了RACScheduler类的使用。将针对RACScheduler类进行深入的剖析。


    RACScheduler类的使用

    先从上图的代码中可以发现,RACScheduler的block代码块中,有执行self.didSubscribe( )代码块的代码,即执行创建信号时的代码块,也就意味着此处的schedule代码块是必须执行。
    跳转进入查看schedule方法,可以发现有多个基于RACScheduler的子类,都有该实现方法。
    在RACScheduler类中,有三种子类:RACImmediateScheduler、RACSubscriptionScheduler和RACQueueScheduler


    schedule方法跳转列表
    在RACImmediateScheduler子类看到schedule方法中,是立即执行block代码块。
    - (RACDisposable *)schedule:(void (^)(void))block {
        NSCParameterAssert(block != NULL);
    
        block();
        return nil;
    }
    

    接着是RACSubscriptionScheduler子类中的schedule方法实现。

    - (RACDisposable *)schedule:(void (^)(void))block {
        NSCParameterAssert(block != NULL);
    
        if (RACScheduler.currentScheduler == nil) return [self.backgroundScheduler schedule:block];
    
        block();
        return nil;
    }
    

    在RACSubscriptionScheduler子类schedule方法中,在执行代码块之前,会先判断当前线程、当前队列是否为nil。若不为nil,则会在后台开启一个串行异步线程队列。而self.backgroundScheduler通过[RACScheduler scheduler]创建并实例化的,最终可以追溯到以下代码中:

    + (RACScheduler *)schedulerWithPriority:(RACSchedulerPriority)priority name:(NSString *)name {
        return [[RACTargetQueueScheduler alloc] initWithName:name targetQueue:dispatch_get_global_queue(priority, 0)];
    }
    

    上述代码意味着是由RACTargetQueueScheduler类初始化,而RACTargetQueueScheduler是RACQueueScheduler的子类。
    而RACTargetQueueScheduler类实例化方法实现中,使用GCD在目标线程里创建了一个串行队列。


    RACTargetQueueScheduler类实例化方法实现

    那么,此时来看下RACQueueScheduler类的schedule方法实现:

    - (RACDisposable *)schedule:(void (^)(void))block {
        NSCParameterAssert(block != NULL);
    
        RACDisposable *disposable = [[RACDisposable alloc] init];
    
        dispatch_async(self.queue, ^{
            if (disposable.disposed) return;
            [self performAsCurrentScheduler:block];
        });
    
        return disposable;
    }
    

    此处使用GCD开启了一个异步线程,在后台执行下一步操作,作为当前的Scheduler去执行。所以说,RACQueueScheduler类实现的schedule方法是在后台创建一个串行队列异步线程来实现最终的代码块执行。


    performAsCurrentScheduler方法实现

    在该方法中,首先找到当前的Scheduler队列;然后从当前线程字典中找到关于RACSchedulerCurrentSchedulerKey键值并将RACScheduler自己赋值给它。
    如果当前Scheduler队列不为空,则会把当前的Scheduler队列存入到当前线程字典的RACSchedulerCurrentSchedulerKey键值中;若为空,则把当前线程字典的RACSchedulerCurrentSchedulerKey键值内容全部删除。一旦删除,意味着当前线程中的队列已不存在。当队列不存在时,会利用Objective-C的动态机制,会自动修复重启当前的队列。
    上面有一段代码:

        @autoreleasepool {
            block();
        }
    

    此段代码中的block执行时,也就是创建RACSignal信号的block中,会有临时变量的产生,autoreleasepool意味着延迟释放。其中涉及到runloop知识范围,此处不做深入讨论。

    以上内容主要讲解了RACScheduler类以及三种子类的作用与实现过程原理,后续会继续探究RAC内部实现的具体流程。

    相关文章

      网友评论

        本文标题:RAC(ReactiveCocoa)介绍(六)——RACSche

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